Which Cloud Dataflow / Beam feature should you use to aggregate data in an unbounded data source every hour based on the time when the data entered the pipeline?
A) An hourly watermark
B) An event time trigger
C) The with Allowed Lateness method
D) A processing time trigger

Question

Quizplus · Accepted Answer

The Answer of Which Cloud Dataflow / Beam feature should you use to aggregate data in an unbounded data source every hour based on the time when the data entered the pipeline?
A) An hourly watermark
B) An event time trigger
C) The with Allowed Lateness method
D) A processing time trigger

Which Cloud Dataflow / Beam Feature Should You Use to Aggregate