Module context 

Management of dataflow-local state, like arrangements, while building a dataflow.

Structs

CollectionBundle

A bundle of the various ways a collection can be represented.

Context

Dataflow-local collections and arrangements.

PendingWork 🔒

PendingWorkOk 🔒

Pending work for the Ok-only variant of flat_map_core_fallible. Holds a single capability since the operator has only one output port.

Enums

ArrangementFlavor

Describes flavor of arrangement: local or imported trace.

Constants

REFUEL 🔒

Number of output records the arrangement flat_map operators may produce before yielding. See ArrangementFlavor::flat_map for the fuel rationale; the constant is a pragmatic compromise and not tuned empirically.

Functions

walk_cursor 🔒

Walk a cursor, calling emit for each consolidated (key, val, time, diff) tuple. If key is set, the cursor is seeked to it and only values for that key are produced.

Type Aliases

ECB 🔒

Container builder used for the err output of every flat_map variant. Pre-refactor the merged Ok/Err stream flowed through a ConsolidatingContainerBuilder before the map_fallible demux split it; we preserve that consolidation here so errors with the same (error, time) cancel within a batch rather than propagating to downstream.

Session 🔒

Type alias for a timely output Session whose capability is a Capability<T>. The container builder CB is left to the caller; sessions can therefore drive consolidating, capacity, or (in the future) columnar output builders without changing call sites.