DEA
Data Processing & Transformations
medium
Question 14 of 62

A data engineer has a PySpark DataFrame orders and wants to calculate the total order amount grouped by customer_id. Which PySpark code correctly achieves this?

Aorders.select(col(\customer_id\), sum(col(\amount\)))
Borders.groupBy(\customer_id\).agg(sum(col(\amount\)).alias(\total_amount\))
Corders.filter(col(\customer_id\)).count()
Dorders.withColumn(\total_amount\, sum(col(\amount\)))

More Data Processing & Transformations Questions

62 questions

Full Databricks Certified Data Engineer Associate Practice Test

All topics covered

All Databricks Certified Data Engineer Associate Questions

Browse by topic

Related Questions

In Apache Spark, what is the difference between a transformation and an action?...

easy

A data engineer wants to add a new column `discounted_price` to a PySpark DataFrame `df` that equals...

easy

What does the `MERGE INTO` SQL statement do in Delta Lake?...

easy

A data engineer writes the following Spark SQL to query a Delta table:\n\n```sql\nSELECT customer_id...

medium

A data engineer needs to join a large `transactions` DataFrame with a small `lookup` DataFrame that ...

medium
View all Data Processing & Transformations questions

Educational Content — CertQnA practice questions are written against official exam objectives, covering the same domains tested on the real exam. All content is original and independent — not actual exam questions, not affiliated with any certification vendor. Learn more about our content policy

Discussion

Be the first to share your understanding of this concept

⚠️ Discussion is for concept clarification only. Do not share or request actual exam questions or answers.

Sign in to join the discussion

Sign InCreate free account