mz_compute::sink::materialized_view

Type Alias DesiredStreams

Source 
type DesiredStreams<S> = OkErr<Stream<S, (Row, Timestamp, Diff)>, Stream<S, (DataflowError, Timestamp, Diff)>>;
Expand description

Type of the desired stream, split into Ok and Err streams.

Aliased Type§

struct DesiredStreams<S> {
    ok: StreamCore<S, Vec<(Row, Timestamp, Overflowing<i64>)>>,
    err: StreamCore<S, Vec<(DataflowError, Timestamp, Overflowing<i64>)>>,
}

Fields§

§ok: StreamCore<S, Vec<(Row, Timestamp, Overflowing<i64>)>>§err: StreamCore<S, Vec<(DataflowError, Timestamp, Overflowing<i64>)>>