Module timely::progress

Progress tracking mechanisms to support notification in timely dataflow

Reexports

pub use self::operate::Operate;

pub use self::nested::Subgraph;

pub use self::nested::SubgraphBuilder;

pub use self::nested::Source;

pub use self::nested::Target;

pub use self::timestamp::Timestamp;

pub use self::timestamp::PathSummary;

pub use self::change_batch::ChangeBatch;

pub use self::frontier::Antichain;

Modules

broadcast	Broadcasts progress information among workers.
change_batch	A collection of updates of the form (T, i64).
frontier	Tracks minimal sets of mutually incomparable elements of a partial order.
nested	Coordination of progress information between a scope-as-operator and its children operators.
operate	Methods which describe an operators topology, and the progress it makes.
timestamp	A partially ordered measure of progress at each timely dataflow location.