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 Definitions

Bundle

The input to and output from timely dataflow communication channels.