Type Alias RowValArrangement 

pub type RowValArrangement<'scope, T, V> = Arranged<'scope, TraceAgent<RowValSpine<V, T, Diff>>>;

Aliased Type

pub struct RowValArrangement<'scope, T, V> {
    pub stream: Stream<'scope, <TraceAgent<Spine<ArcBatch<OrdValBatch<RowValLayout<((Row, V), T, Overflowing<i64>)>>>>> as TraceReader>::Time, Vec<Span<<TraceAgent<Spine<ArcBatch<OrdValBatch<RowValLayout<((Row, V), T, Overflowing<i64>)>>>>> as TraceReader>::Time, <TraceAgent<Spine<ArcBatch<OrdValBatch<RowValLayout<((Row, V), T, Overflowing<i64>)>>>>> as TraceReader>::Batch>>>,
    pub trace: TraceAgent<Spine<ArcBatch<OrdValBatch<RowValLayout<((Row, V), T, Overflowing<i64>)>>>>>,
}

Fields

stream: Stream<'scope, <TraceAgent<Spine<ArcBatch<OrdValBatch<RowValLayout<((Row, V), T, Overflowing<i64>)>>>>> as TraceReader>::Time, Vec<Span<<TraceAgent<Spine<ArcBatch<OrdValBatch<RowValLayout<((Row, V), T, Overflowing<i64>)>>>>> as TraceReader>::Time, <TraceAgent<Spine<ArcBatch<OrdValBatch<RowValLayout<((Row, V), T, Overflowing<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.

Unchecked assumption: each update in a batch has a time greater or equal to some time in the stamp of the message carrying it. In particular, a message with an empty stamp carries no updates.

trace: TraceAgent<Spine<ArcBatch<OrdValBatch<RowValLayout<((Row, V), T, Overflowing<i64>)>>>>>

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