Skip to main content

Module window

Module window 

Source
Expand description

Window assignment, emit strategies, and CDC types for stream processing.

Structs§

ChangelogRecord
Changelog record with Z-set weight for CDC pipelines.
TumblingWindowAssigner
Tumbling window assigner: fixed-size, non-overlapping windows aligned to epoch.
WindowId
Unique identifier for a window (start inclusive, end exclusive, milliseconds).

Enums§

CdcOperation
CDC operation type with Z-set weights.
EmitStrategy
Strategy for when window results should be emitted.

Traits§

WindowAssigner
Trait for assigning events to windows.

Type Aliases§

WindowIdVec
Window assignment results. Inline storage for up to 4 windows (avoids heap).