Module timely::dataflow::channels

source ·
Expand description

Structured communication between timely dataflow operators.


  • Parallelization contracts, describing how data must be exchanged between operators. Parallelization contracts, describing requirements for data movement along dataflow edges.
  • A collection of types that may be pulled from.
  • A collection of types that may be pushed at.


  • A serializable representation of timestamped data.

Type Aliases§

  • The input to and output from timely dataflow communication channels.