timely/dataflow/operators/aggregation/
mod.rs

1//! Aggregation operators of various flavors
2//!
3//! Two traits, `Aggregate` and `StateMachine`, which support the accumulation of streamed information.
4//!
5//! `Aggregate` accumulates records within times, and releases the accumulations once the time is complete.
6//!
7//! `StateMachine` responds to a sequence of keyed events, maintaining and updating a state for each key.
8//! The user logic may produce output records for each transition, and optionally de-register the state to
9//! clean up when appropriate.
10//!
11//! The two methods are often combined, using first `Aggregate` to reduce the volume of information, and then
12//! `StateMachine` to track an accumulation across timestamps.
13
14pub use self::aggregate::Aggregate;
15pub use self::state_machine::StateMachine;
16
17pub mod state_machine;
18pub mod aggregate;