Trait persist::operators::source::PersistedSource

pub trait PersistedSource<G: Scope<Timestamp = u64>, K: TimelyData, V: TimelyData> {
    fn persisted_source(
        &mut self, 
        read: StreamReadHandle<K, V>, 
        as_of_frontier: &Antichain<u64>
    ) -> Stream<G, (Result<(K, V), String>, u64, isize)>;
}

A Timely Dataflow operator that mirrors a persisted stream.

Required methods

fn persisted_source(
    &mut self,
    read: StreamReadHandle<K, V>,
    as_of_frontier: &Antichain<u64>
) -> Stream<G, (Result<(K, V), String>, u64, isize)>

Emits a snapshot of the persisted stream taken as of this call and listens for any new data added to the persisted stream after that.

Implementors

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