Module differential_dataflow::input

Input sessions for simplified collection updates.

Although users can directly manipulate timely dataflow streams as collection inputs, the InputSession type can make this more efficient and less error-prone. Specifically, the type batches up updates with their logical times and ships them with coarsened timely dataflow capabilities, exposing more concurrency to the operator implementations than are evident from the logical times, which appear to execute in sequence.

Structs

InputSession

An input session wrapping a single timely dataflow capability.

Traits

Input

Create a new collection and input handle to control the collection.