Module timely::dataflow::channels

Structured communication between timely dataflow operators.

Modules

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

Structs

• Message
  A serializable representation of timestamped data.

Type Aliases

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