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::Source;

pub use self::nested::Target;

pub use self::timestamp::Timestamp;

pub use self::timestamp::PathSummary;

pub use self::count_map::CountMap;

pub use self::frontier::Antichain;

Modules

broadcast	Broadcasts progress information among workers.
count_map	A mapping from general types T to i64, with zero values absent.
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.