Process unbounded events using event time, watermarks, windows, state, checkpoints, and late-data policies.
