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.