Ultimate access to all questions.
Upgrade Now π
Sign in to unlock AI tutor
To aggregate data from an unbounded source every hour based on the time it entered the pipeline in Cloud Dataflow/Beam, which feature should you utilize?
A
An hourly watermark
B
An event time trigger
C
The with Allowed Lateness method
D
A processing time trigger