Modules§
- agg_
group 🔒 - agg_
state 🔒 - agg_
state_ 🔒cache - Object-safe version of
StateCachefor aggregation. - distinct 🔒
- hash_
agg 🔒 - minput 🔒
- simple_
agg 🔒 - stateless_
simple_ 🔒agg
Structs§
- AggExecutor
Args - Arguments needed to construct an
XxxAggExecutor. - Hash
AggExecutor HashAggExecutorcould process large amounts of data using a state backend. It works as follows:- Hash
AggExecutor Extra Args - Extra arguments needed to construct an
HashAggExecutor. - Simple
AggExecutor SimpleAggExecutoris the aggregation operator for streaming system. To create an aggregation operator, states and expressions should be passed along the constructor.- Simple
AggExecutor Extra Args - Stateless
Simple AggExecutor
Enums§
- AggState
Storage - Represents the persistent storage of aggregation state.