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 (F063)

lag_lead

LAG/LEAD Operator

lookup_join

Lookup Join Operators

partitioned_topk

Partitioned Top-K Operator

session_window

Session Window Operators

sliding_window

Sliding Window Operators

stream_join

Stream-Stream Join Operators

temporal_join

Temporal Join Operators (F021)

topk

Streaming Top-K Operator

watermark_sort

Watermark-Bounded Sort Operator

window

Window Operators

window_sort

Window-Local Sort Operator

Structs

Event

An event flowing through the system

OperatorContext

Context provided to operators during processing

OperatorState

Serialized operator state for checkpointing

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.