A streaming DataFrame contains raw JSON data in a `payload` column. A team needs to extract the `temperature` field from the JSON and add it as a new column, while keeping all other columns. Which code achieves this?

df.selectExpr("payload.temperature AS temperature")

df.withColumn("temperature", col("payload").getField("temperature"))

df.select(get_json_object(col("payload"), "$.temperature").alias("temperature"))

df.withColumn("temperature", get_json_object(col("payload"), "$.temperature"))

DatabricksCertified Associate Developer for Apache Spark

Domain 5Objective 3

Perform Basic Operations on Streaming DataFrames and Streaming Datasets, Such as Selection, Projection, Window and Aggregation. ASSOCIATE-DEVELOPER-APACHE-SPARK Practice Questions (Page 2)

Part of the Structured Streaming domain, which accounts for 10% of the ASSOCIATE-DEVELOPER-APACHE-SPARK exam. Databricks does not publish an official question count, but from its 90-minute exam (~35–60 total, ~4–6 in this domain), expect 1–2 from this objective — we provide 15 practice questions to prepare you well beyond it. (estimate)

15questions here

3free pages

7concepts

10%of the exam

Questions 6–10

6application · medium
A streaming DataFrame contains raw JSON data in a `payload` column. A team needs to extract the `temperature` field from the JSON and add it as a new column, while keeping all other columns. Which code achieves this?
Select an answer first
7foundation · easy
Which operation removes one or more columns from a streaming DataFrame?
Select an answer first
8foundation · easy
Which method allows you to select columns from a streaming DataFrame using SQL expressions?
Select an answer first
9foundation · easy
Which aggregation function is used to compute the average of a numeric column in a streaming DataFrame?
Select an answer first
10foundation · easy
Which method is used to specify how long to wait for late data in a streaming aggregation?
Select an answer first

Finished these 5 questions?

Review the revealed explanations, or continue through the curriculum.

Next 5 questions →Back to ASSOCIATE-DEVELOPER-APACHE-SPARK

Free Basic Practice is a study aid with revealable answers — not a scored exam. Examers.io is independent and not affiliated with or endorsed by Databricks. “ASSOCIATE-DEVELOPER-APACHE-SPARK” is a trademark of its owner, used for identification only.

Perform Basic Operations on Streaming DataFrames and Streaming Datasets, Such as Selection, Projection, Window and Aggregation. ASSOCIATE-DEVELOPER-APACHE-SPARK Practice Questions (Page 2)

Questions 6–10

A streaming DataFrame contains raw JSON data in a `payload` column. A team needs to extract the `temperature` field from the JSON and add it as a new column, while keeping all other columns. Which code achieves this?

Which operation removes one or more columns from a streaming DataFrame?

Which method allows you to select columns from a streaming DataFrame using SQL expressions?

Which aggregation function is used to compute the average of a numeric column in a streaming DataFrame?

Which method is used to specify how long to wait for late data in a streaming aggregation?

Keep studying — Structured Streaming