Function dataflow::render::envelope_none::persist_and_replay [−][src]
pub(crate) fn persist_and_replay<G>(
source_name: &str,
stream: &Stream<G, (Result<Row, DecodeError>, Timestamp, Diff)>,
as_of_frontier: &Antichain<Timestamp>,
persist_config: PersistentEnvelopeNoneConfig<Result<Row, DecodeError>>
) -> (Stream<G, (Result<Row, DecodeError>, Timestamp, Diff)>, Stream<G, (DataflowError, Timestamp, Diff)>) where
G: Scope<Timestamp = Timestamp>,
Expand description
Persists the given input stream, passes through the data it carries and replays previously persisted updates when starting up.
This will filter out and retract replayed updates that are not beyond the upper_seal_ts
given
in persist_config
.