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 a 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;