Module operator 

Stream operators for transforming and processing events

This module provides the core operators for stream processing pipelines:

• Map: Transform events one-to-one
• Filter: Select events based on predicates
• FlatMap: Transform events one-to-many
• KeyBy: Partition events by key
• Window: Assign events to windows
• Aggregate: Compute aggregations over windows

Structs

AggregateOperator

Aggregate operator - computes aggregations over windows

DeduplicationOperator

Deduplication operator - filters duplicate events

DeduplicationStats

Statistics for deduplication operator

FilterOperator

Filter operator - selects events based on a predicate

FlatMapOperator

FlatMap operator - transforms events one-to-many

KeyByOperator

KeyBy operator - partitions events by key

MapOperator

Map operator - transforms events one-to-one

OperatorChain

Chain of operators that can be applied sequentially

OperatorContext

Context provided to operators during execution

WindowOperator

Window operator - assigns events to windows

Traits

StreamOperator

Trait for stream operators