
Ultimate access to all questions.
You are managing a streaming pipeline using Dataflow with hopping windows to group incoming data. However, some late data is not being recognized as such, causing inaccuracies in downstream aggregations. What measures should you implement to correctly capture and process this late data within its intended window?
A
Switch to tumbling windows to eliminate overlapping window periods, ensuring data is grouped within fixed intervals.
B
Implement session windows, grouping data based on specific activity patterns to better manage late arrivals.
C
Adjust the hopping window size to allow more time for late data to be included in the grouping.
D
Utilize watermarks to establish expected data arrival times, enabling the inclusion of late data within the correct window.