Trait persist::operators::replay::Replay[−][src]

pub trait Replay<G: Scope<Timestamp = u64>, K: TimelyData, V: TimelyData> {
    fn replay(
        &self, 
        snapshot: Result<DecodedSnapshot<K, V>, Error>, 
        as_of_frontier: &Antichain<u64>
    ) -> Stream<G, (Result<(K, V), String>, u64, isize)>;
}

Expand description

Extension trait for Stream.

Required methods

fn replay(
    &self,
    snapshot: Result<DecodedSnapshot<K, V>, Error>,
    as_of_frontier: &Antichain<u64>
) -> Stream<G, (Result<(K, V), String>, u64, isize )>

Emits each record in a snapshot.

Implementors

impl<G, K, V> Replay<G, K, V> for G where
    G: Scope<Timestamp = u64>,
    K: TimelyData + Codec,
    V: TimelyData + Codec,