Type Alias mz_compute::typedefs::RowArrangement

source ·
pub type RowArrangement<S> = Arranged<S, TraceAgent<Spine<Rc<OrdKeyBatch<RowLayout<((Row, ()), <S as ScopeParent>::Timestamp, Diff)>>>, MergeBatcher<Vec<((Row, ()), <S as ScopeParent>::Timestamp, Diff)>, ColumnationChunker<((Row, ()), <S as ScopeParent>::Timestamp, Diff)>, ColumnationMerger<((Row, ()), <S as ScopeParent>::Timestamp, Diff)>, <S as ScopeParent>::Timestamp>, RcBuilder<OrdKeyBuilder<RowLayout<((Row, ()), <S as ScopeParent>::Timestamp, Diff)>, TimelyStack<((Row, ()), <S as ScopeParent>::Timestamp, Diff)>>>>>>;

Aliased Type§

struct RowArrangement<S> {
    pub stream: StreamCore<S, Vec<<TraceAgent<Spine<Rc<OrdKeyBatch<RowLayout<((Row, ()), <S as ScopeParent>::Timestamp, i64)>>>, MergeBatcher<Vec<((Row, ()), <S as ScopeParent>::Timestamp, i64)>, ColumnationChunker<((Row, ()), <S as ScopeParent>::Timestamp, i64)>, ColumnationMerger<((Row, ()), <S as ScopeParent>::Timestamp, i64)>, <S as ScopeParent>::Timestamp>, RcBuilder<OrdKeyBuilder<RowLayout<((Row, ()), <S as ScopeParent>::Timestamp, i64)>, TimelyStack<((Row, ()), <S as ScopeParent>::Timestamp, i64)>>>>> as TraceReader>::Batch>>,
    pub trace: TraceAgent<Spine<Rc<OrdKeyBatch<RowLayout<((Row, ()), <S as ScopeParent>::Timestamp, i64)>>>, MergeBatcher<Vec<((Row, ()), <S as ScopeParent>::Timestamp, i64)>, ColumnationChunker<((Row, ()), <S as ScopeParent>::Timestamp, i64)>, ColumnationMerger<((Row, ()), <S as ScopeParent>::Timestamp, i64)>, <S as ScopeParent>::Timestamp>, RcBuilder<OrdKeyBuilder<RowLayout<((Row, ()), <S as ScopeParent>::Timestamp, i64)>, TimelyStack<((Row, ()), <S as ScopeParent>::Timestamp, i64)>>>>>,
}

Fields§

§stream: StreamCore<S, Vec<<TraceAgent<Spine<Rc<OrdKeyBatch<RowLayout<((Row, ()), <S as ScopeParent>::Timestamp, i64)>>>, MergeBatcher<Vec<((Row, ()), <S as ScopeParent>::Timestamp, i64)>, ColumnationChunker<((Row, ()), <S as ScopeParent>::Timestamp, i64)>, ColumnationMerger<((Row, ()), <S as ScopeParent>::Timestamp, i64)>, <S as ScopeParent>::Timestamp>, RcBuilder<OrdKeyBuilder<RowLayout<((Row, ()), <S as ScopeParent>::Timestamp, i64)>, TimelyStack<((Row, ()), <S as ScopeParent>::Timestamp, i64)>>>>> as TraceReader>::Batch>>

A stream containing arranged updates.

This stream contains the same batches of updates the trace itself accepts, so there should be no additional overhead to receiving these records. The batches can be navigated just as the batches in the trace, by key and by value.

§trace: TraceAgent<Spine<Rc<OrdKeyBatch<RowLayout<((Row, ()), <S as ScopeParent>::Timestamp, i64)>>>, MergeBatcher<Vec<((Row, ()), <S as ScopeParent>::Timestamp, i64)>, ColumnationChunker<((Row, ()), <S as ScopeParent>::Timestamp, i64)>, ColumnationMerger<((Row, ()), <S as ScopeParent>::Timestamp, i64)>, <S as ScopeParent>::Timestamp>, RcBuilder<OrdKeyBuilder<RowLayout<((Row, ()), <S as ScopeParent>::Timestamp, i64)>, TimelyStack<((Row, ()), <S as ScopeParent>::Timestamp, i64)>>>>>

A shared trace, updated by the Arrange operator and readable by others.