timely 0.2.0

A low-latency data-parallel dataflow system in Rust
Documentation 
1
2
3
4
5
6
7
8
9
10
11
12
13

//! Structured communication between timely dataflow operators.

pub use self::message::Message;
pub use self::message::Content;

/// A collection of types that may be pushed at.
pub mod pushers;
/// A collection of types that may be pulled from.
pub mod pullers;
/// Types relating to batching of timestamped records.
pub mod message;
/// Parallelization contracts, describing how data must be exchanged between operators.
pub mod pact;