Skip to main content

Module collection

Module collection 

Source
Expand description

The COLLECTION face of the columnar subsystem: the columnar data as a differential-dataflow collection.

RecordedUpdates is the stream container that flows on edges; it is built input-side by Builder, shuffled by Pact, and mapped over by the columnar operators (join_function, leave_dynamic, as_recorded_updates). These derive from the same columnar data as the trace face, and the two are linked by two bridge operators: the trace’s Chunker (collection → batch) and this face’s as_recorded_updates (trace → collection).

  • containerRecordedUpdates + its Negate/Enter/Leave/ResultsIn impls + the wire codec.
  • builder — the input-side ContainerBuilder.
  • exchange — the shuffle Pact.
  • operatorsjoin_function / leave_dynamic / as_recorded_updates.

Re-exports§

pub use container::RecordedUpdates;
pub use builder::ValBuilder as Builder;
pub use exchange::ValPact as Pact;
pub use operators::as_recorded_updates;
pub use operators::join_function;
pub use operators::leave_dynamic;
pub use operators::DynTime;

Modules§

builder
ValColBuilder: the ContainerBuilder that feeds the dataflow input side.
container
RecordedUpdates<U>: the columnar stream container.
exchange
Exchange / parallelization contract for RecordedUpdates.
operators
Dataflow operators over the columnar RecordedUpdates container — the collection-level surface of the columnar chunk.