🔥 40% Off Crucial Exams Memberships — Deal ends today!

1 hour, 57 minutes remaining!

GCP Professional Data Engineer Practice Question

A Dataflow streaming pipeline processes IoT sensor events using event‐time tumbling windows and a trigger configured to emit results "after watermark passes end of window". Sensors sometimes buffer data, so events can reach the pipeline minutes late and out of order. How does the watermark influence when the pipeline publishes the aggregated window results?

  • It represents processing (wall-clock) time; when real time moves past the window boundary, results are published regardless of event timestamps.

  • It is a user-configured timer that the Dataflow service reads to decide when to add or remove worker instances for autoscaling.

  • It is Dataflow's estimate of event-time completeness; once it surpasses a window's end timestamp, the specified trigger fires and the window's aggregated results are emitted, even if a few late elements might still arrive later.

  • It sets the maximum lateness period; when that duration expires after window close, late elements are discarded and only then are results emitted.

GCP Professional Data Engineer
Ingesting and processing the data
Your Score:
Settings & Objectives
Random Mixed
Questions are selected randomly from all chosen topics, with a preference for those you haven’t seen before. You may see several questions from the same objective or domain in a row.
Rotate by Objective
Questions cycle through each objective or domain in turn, helping you avoid long streaks of questions from the same area. You may see some repeat questions, but the distribution will be more balanced across topics.

Check or uncheck an objective to set which questions you will receive.

Bash, the Crucial Exams Chat Bot
AI Bot