Dataflow windowing

What are the three types of windows provided by Dataflow?

• Fixed, interval, continuous

• Fixed, sliding, sessions

• Timed, untimed, sessions

• Periodic, cyclic, sessions

What is another name for Fixed Window in Dataflow?

• Hopping Window

• Session Window

• Tumbling Window

• Periodic Window

How often do new windows open in the given example of a sliding window with arguments 30 and 5?

• Every 30 seconds

• Every 5 seconds

• Every 60 seconds

• Every 10 seconds

What defines the timing of session windows?

• A fixed interval

• The length of the window

• A minimum gap duration and another element

• The number of data elements

What is a watermark in Dataflow?

• The time of the latest processed message

• The time of the oldest unprocessed message

• The lag time between the oldest unprocessed message and the latest processed message

• The average processing time of messages

What happens to late data in Dataflow by default?

• It is reprocessed

• It is discarded

• It is stored for later use

• It is sent to a separate queue

What is the default windowing configuration behavior in Apache Beam?

• It allows late data by default

• It discards late data by default

• It processes late data only during non-peak hours

• It requires manual intervention for late data

What is an example of a data-driven trigger in Dataflow?

• AfterProcessingTime

• AfterWatermark

• AfterCount

• AfterTimeInterval

What does the combination of several types of triggers in streaming pipelines allow?

• Emitting results only at the end of the window

• Limiting the amount of data processed

• Opening a world of possibilities for result emission

• Reducing the processing time

What does the composite trigger in the provided code example do?

• It activates after one-hundred elements or every 60 seconds, whichever comes first

• It activates every 30 seconds

• It activates only after the watermark

• It activates only after all data is processed