Expand description

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.


  • An input session wrapping a single timely dataflow capability.


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