Windowing and Event-Time Processing

Enables grouping of data based on time attributes, supporting tumbling, hopping, and session windows with late-data handling (watermarking).