Module windowing 

Windowing and watermarking for event-time processing.

Structs

CountTrigger

Count-based trigger that fires after a certain number of elements.

EventTimeSessionWindows

Event-time session windows.

EventTimeTrigger

Event-time trigger that fires when watermark passes window end.

MultiSourceWatermarkManager

Multi-source watermark manager.

PeriodicWatermarkGenerator

Periodic watermark generator.

ProcessingTimeSessionWindows

Processing-time session windows.

PunctuatedWatermarkGenerator

Punctuated watermark generator.

SessionAssigner

Assigner for session windows.

SessionWindow

Session window (dynamic windows based on activity).

SessionWindowConfig

Configuration for session windows.

SlidingAssigner

Assigner for sliding windows.

SlidingWindow

Sliding window (fixed-size, overlapping windows).

SlidingWindowConfig

Configuration for sliding windows.

TumblingAssigner

Assigner for tumbling windows.

TumblingWindow

Tumbling window (fixed, non-overlapping windows).

TumblingWindowConfig

Configuration for tumbling windows.

Watermark

A watermark representing event-time progress.

WatermarkConfig

Configuration for watermark generation.

Window

A window of time for grouping events.

WindowState

State associated with a window.

Enums

TriggerResult

Result of evaluating a trigger.

WatermarkStrategy

Strategy for generating watermarks.

Traits

WatermarkGenerator

Generates watermarks for a stream.

WindowAssigner

Assigns elements to windows.

WindowTrigger

Determines when a window should emit results.