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 */ }