Process real-time streams with correct semantics. Trigger: streaming, windowing, watermarks, event time.
