Skip to main content

PersistStreams

mz_compute::sink::materialized_view

Type Alias PersistStreams 

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

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

Aliased Type§

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

Fields§

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