mz_compute::sink::materialized_view

Type Alias PersistStreams

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

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

Aliased Type§

struct PersistStreams<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>)>>

Implementations

Source§

impl<O, E> OkErr<O, E>

Source

fn new(ok: O, err: E) -> Self