Skip to main content

SinkBatchStream

Type Alias SinkBatchStream 

Source
pub(crate) type SinkBatchStream<'scope> = StreamVec<'scope, Timestamp, <TraceAgent<OrdValSpine<Option<Row>, Row, Timestamp, Diff>> as TraceReader>::Batch>;
Expand description

Stream of arrangement batches handed to SinkRender::render_sink.

This is Arranged::stream with the trace reader dropped: sinks only need batch-level access (no random-access reads via a cursor), so we don’t keep a TraceAgent alive. Dropping the reader lets the spine’s compaction frontiers advance to the empty antichain, so the arrange operator can aggressively compact / release batch state as updates flow through.

Aliased Type§

pub(crate) struct SinkBatchStream<'scope> { /* private fields */ }