PySpark Certification Practice Test 09

Complete the Logic / Best Coding Solution

Question 1 of 20

📋 Multiple Choice

Question 161

A retail company wants the latest customer record. Input: customer_id | city | update_date ------------|----------|------------ 1 | Bangalore| 2024-01-01 1 | Chennai | 2024-02-01 2 | Mumbai | 2024-01-15 Which window function is the BEST choice?

✓

A. row_number()

B. count()

C. avg()

D. min()

Answer

✅ A. row_number()

Answered: 0 / 20

PySpark Certification Practice Test 09

Complete the Logic / Best Coding Solution

Insightful Saga — Modern Data Engineering Certification Preparation

Question 161

A. row_number()

B. count()

C. avg()

D. min()

Answer: ✅ A. row_number()

Question 162

A banking company wants the Top 5 customers by balance per branch. Which approach is most suitable?

A. Window + row_number()

B. distinct()

C. union()

D. collect()

Answer: ✅ A. Window + row_number()

Question 163

A telecom company wants: Current Month Usage Previous Month Usage Difference Which function should be used?

A. lag()

B. lead()

C. count()

D. sum()

Answer: ✅ A. lag()

Question 164

Find duplicate records based on: customer_id order_id Best solution?

A. groupBy().count()

B. collect()

C. cache()

D. coalesce()

Answer: ✅ A. groupBy().count()

Question 165

A dataset contains: salary Requirement: Find the 3rd highest salary. Best window function?

A. dense_rank()

B. lag()

C. sum()

D. lead()

Answer: ✅ A. dense_rank()

Question 166

Input: customer_id transaction_date amount Requirement: Running Total. Best approach?

A. Window + sum()

B. groupBy()

C. collect()

D. distinct()

Answer: ✅ A. Window + sum()

Question 167

A healthcare company receives late-arriving records. Requirement: Keep latest version per patient. Most suitable pattern?

A. row_number + desc timestamp

B. count()

C. min()

D. union()

Answer: ✅ A

Question 168

Input: employee_id salary department Requirement: Highest-paid employee in each department. Best solution?

A. row_number partitioned by department

B. collect()

C. full join

D. cache()

Answer: ✅ A

Question 169

A table contains: customer_id event_date Requirement: Find consecutive events. Primary functions?

A. lag() + datediff()

B. sum()

C. avg()

D. union()

Answer: ✅ A

Question 170

Requirement: Remove duplicates but keep the latest timestamp row. Most suitable logic?

A. row_number over timestamp desc

B. distinct()

C. count()

D. collect()

Answer: ✅ A

Question 171

Input: sales_date sales_amount Requirement: 7-Day Moving Average. Best solution?

A. Window Between

B. distinct()

C. left join

D. repartition()

Answer: ✅ A

Question 172

A logistics company wants: Current Shipment Cost Previous Shipment Cost Cost Difference Which pattern should be used?

A. lag()

B. dense_rank()

C. count()

D. cache()

Answer: ✅ A

Question 173

Requirement: Identify customers who placed orders on 3 consecutive days. Main concepts?

A. lag + datediff + window

B. union

C. cache

D. broadcast

Answer: ✅ A

Question 174

A retail company wants: Top Product per Category Best coding approach?

A. row_number partitionBy(category)

B. collect

C. repartition(1)

D. distinct

Answer: ✅ A

Question 175

Requirement: Find customers whose current order amount is greater than previous order amount. Best function?

A. lag()

B. lead()

C. rank()

D. avg()

Answer: ✅ A

Question 176

A bank wants: Monthly Balance Trend with month-over-month comparison. Which function is most appropriate?

A. lag()

B. collect()

C. union()

D. broadcast()

Answer: ✅ A

Question 177

Input: transaction_date amount Requirement: Cumulative yearly revenue. Best solution?

A. Window + sum()

B. distinct()

C. min()

D. collect()

Answer: ✅ A

Question 178

A manufacturing company wants anomalies where: today_temperature > previous_temperature * 2 Best window function?

A. lag()

B. count()

C. union()

D. cache()

Answer: ✅ A

Question 179

Find customers with no orders. Best join type?

A. Left Anti Join

B. Inner Join

C. Cross Join

D. Right Join

Answer: ✅ A

Question 180

A senior PySpark interviewer asks: "Which PySpark concepts are most important for advanced analytics problems?"

A. Window Functions

B. print()

C. show()

D. limit()

Answer: ✅ A --- --- title: PySpark Certification Practice Test 10 description: Debug The ETL Pipeline --- # PySpark Certification Practice Test 10