Type Alias PersistStreams 

type PersistStreams<'s> = OkErr<StreamVec<'s, Timestamp, (Row, Timestamp, Diff)>, StreamVec<'s, Timestamp, (DataflowError, Timestamp, Diff)>>;

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

Aliased Type

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

Fields

ok: Stream<'s, Timestamp, Vec<(Row, Timestamp, Overflowing<i64>)>>

err: Stream<'s, Timestamp, Vec<(DataflowError, Timestamp, Overflowing<i64>)>>