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