DATABRICKS-CERTIFIED-DATA-ENGINEER-ASSOCIATE · Question #40
A data engineer has joined an existing project and they see the following query in the project repository: CREATE STREAMING LIVE TABLE loyal_customers AS SELECT customer_id - FROM…
The correct answer is C. The customers table is a streaming live table. In Delta Live Tables SQL, the STREAM() function wraps a LIVE table reference to indicate that the source table should be read as a stream - processing only new or changed records incrementally rather than reprocessing the entire table on each run. The STREAM() function is…
Question
Options
- AThe STREAM function is not needed and will cause an error.
- BThe table being created is a live table.
- CThe customers table is a streaming live table.
- DThe customers table is a reference to a Structured Streaming query on a PySpark DataFrame.
- EThe data in the customers table has been updated since its last run.
How the community answered
(23 responses)- A4% (1)
- C91% (21)
- D4% (1)
Explanation
In Delta Live Tables SQL, the STREAM() function wraps a LIVE table reference to indicate that the source table should be read as a stream - processing only new or changed records incrementally rather than reprocessing the entire table on each run. The STREAM() function is required specifically when the source (LIVE.customers) is itself defined as a STREAMING LIVE TABLE. If customers were a standard batch LIVE TABLE, the STREAM() wrapper would not be appropriate. The function does not relate to PySpark DataFrames (option D) - it is purely a DLT SQL construct. It is not an error (option A), nor is it triggered by data updates since last run in the way option E implies.
Topics
Community Discussion
No community discussion yet for this question.