Module timely::progress
[−]
[src]
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 |
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. |