Skip to main content

Module operator

Module operator 

Source
Expand description

Streaming operator types and window assigners for stream processing.

Modules§

sliding_window
Sliding (hopping) window assigner.
table_cache
LRU cache and Xor filter for reference table partial-cache mode.
window
Window assignment, emit strategies, and CDC types for stream processing.

Structs§

Event
An event flowing through the system.
OperatorState
Serialized operator state for checkpointing.

Enums§

OperatorError
Errors that can occur in operators.

Type Aliases§

TimerKey
Timer key type optimized for window IDs (16 bytes).