Module timely::dataflow::operators::aggregation

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.

Re-exports

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

Modules

• aggregate
  General purpose intra-timestamp aggregation
• state_machine
  General purpose state transition operator.