A data engineer is designing a system leveraging Lakeflow Declarative Pipeline technology to process real-time truck telemetry data ingested from JSON files in S3 using Auto Loader. The data includes truck_id, timestamp, location, speed, and fuel_level. The system must support two use cases: 1. Near-real-time monitoring of the latest location, speed, and fuel_level per truck_id for the operations team. 2. Daily aggregated reports of total distance traveled and average fuel efficiency per truck_id for the management team. Which approach should the data engineer use for streaming tables and materialized views in the Lakeflow Declarative Pipeline to meet these requirements?
Select an option, then click Submit answer.
Reference / correct answer:
Define a streaming table to ingest and store the raw telemetry data, and create a streaming table to incrementally compute the latest location, speed, and fuel_level per truck_id for real-time monitoring. Create a materialized view to compute the daily aggregated distance and fuel efficiency per truck_id for reporting.
Most accepted answer: C. Define a streaming table to ingest and store the raw telemetry data, and create a streaming table to incrementally compute the latest location, speed, and fuel_level per truck_id for real-time monitoring. Create a materialized view to compute the daily aggregated distance and fuel efficiency per truck_id for reporting.
Community votes: B=1, C=1
Selected Answer: C I correct my answer to C, gemini and calude are making life miserable... today gemini is saying answer is C upvoted 1 times
Selected Answer: B Both Claude and Google Gemini says Answer is B which is cprrect too as fopr real time tracking its good to create a matrialize view which will give the updated result on the fly upvoted 1 times