Work a watermark decision
Choose and explain a watermark policy for a streaming aggregation.
A five-minute revenue window must help marketing pace spend within three minutes, but finance wants a stable number for hourly reporting. Watermark policy should balance action timing, lateness distribution, and correction visibility. The common shortcut is to pick one "final" time for every user. That either delays operators or rewrites history for finance. Before Emit revenue at window close plus one minute and silently update when late events arrive. After Emit a provisional revenue number at plus two minutes with a settling label, then finalize at plus eight minutes and send later events to a correction log. Measure lateness 95…
Sign up free — one personalized lesson every day, matched to your role and goals.
Already have an account? Sign in