What is the purpose of a watermark in Structured Streaming?

To store data in a more efficient format

To handle late data by defining a threshold for how late events can arrive

To filter out all data that arrives late

To increase the processing speed of the stream

A logistics company streams package tracking events (package_id, status, location, timestamp) into a DataFrame. Analysts need a streaming DataFrame containing only the package_id and location columns for a real-time dashboard, excluding all other fields. Which code should they use?

df.filter(col("package_id").isNotNull()).select("package_id", "location")

df.selectExpr("package_id AS id", "location AS loc")

df.select("package_id", "location")

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 3)

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 11–15

11foundation · easy
Which of the following operations can be applied directly to a streaming DataFrame to choose a subset of its columns?
Select an answer first
12foundation · easy
Which operation adds a new column to a streaming DataFrame while keeping all existing columns?
Select an answer first
13foundation · easy
What is the purpose of a watermark in Structured Streaming?
Select an answer first
14application · medium
A logistics company streams package tracking events (package_id, status, location, timestamp) into a DataFrame. Analysts need a streaming DataFrame containing only the package_id and location columns for a real-time dashboard, excluding all other fields. Which code should they use?
Select an answer first
15foundation · easy
Which function is used to define event-time windows for streaming aggregations in Spark Structured Streaming?
Select an answer first

Finished these 5 questions?

Review the revealed explanations, or continue through the curriculum.

No more pagesBack 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 3)

Questions 11–15

Which of the following operations can be applied directly to a streaming DataFrame to choose a subset of its columns?

Which operation adds a new column to a streaming DataFrame while keeping all existing columns?

What is the purpose of a watermark in Structured Streaming?

A logistics company streams package tracking events (package_id, status, location, timestamp) into a DataFrame. Analysts need a streaming DataFrame containing only the package_id and location columns for a real-time dashboard, excluding all other fields. Which code should they use?

Which function is used to define event-time windows for streaming aggregations in Spark Structured Streaming?

Keep studying — Structured Streaming