timely/dataflow/operators/aggregation/
mod.rs

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

pub use self::aggregate::Aggregate;
pub use self::state_machine::StateMachine;

pub mod state_machine;
pub mod aggregate;