Module operator 

Operator Module

Streaming operators for transforming and processing events.

Operator Types

• Stateless: map, filter, flatmap
• Stateful: window, aggregate, join

All operators implement the Operator trait and can be composed into directed acyclic graphs (DAGs) for complex stream processing.

Modules

asof_join

ASOF Join Operators

changelog

Changelog and Retraction Support

lag_lead

LAG/LEAD Operator

partitioned_topk

Partitioned Top-K Operator

session_window

Session Window Operators

sliding_window

Sliding Window Operators

stream_join

Stream-Stream Join Operators

table_cache

LRU cache and Xor filter for reference table partial-cache mode.

temporal_join

Temporal Join Operators

topk

Streaming Top-K Operator

watermark_sort

Watermark-Bounded Sort Operator

window

Window Operators

window_sort

Window-Local Sort Operator

Structs

CheckpointCompleteData

Data for a checkpoint completion.

Event

An event flowing through the system

OperatorContext

Context provided to operators during processing

OperatorState

Serialized operator state for checkpointing

SideOutputData

Data for a late event routed to a named side output.

Timer

A timer registration

Enums

OperatorError

Errors that can occur in operators

Output

Output from an operator

Traits

Operator

Trait implemented by all streaming operators

Type Aliases

OutputVec

Collection type for operator outputs.

TimerKey

Timer key type optimized for window IDs (16 bytes). Re-exported from time module for convenience.