This website uses cookies to ensure you get the best experience.
Learn more.
A streaming pipeline must aggregate by business event time and account for records that arrive after the usual window completion. Which two configuration decisions directly address these requirements? Select 2 answers.
Published
- Increase worker count and assume it resolves all out-of-order event semantics.
- Use arrival time for every event and discard the source timestamp.
- Treat the watermark as a guarantee that no earlier event can ever arrive.
- Define allowed lateness and trigger behavior for the windows.
- Assign timestamps representing when the underlying events occurred.
Comments — 0
Sign in to comment