Trait persist::operators::input::PersistentUnorderedInput

pub trait PersistentUnorderedInput<G: Scope<Timestamp = u64>, K: TimelyData> {
    fn new_persistent_unordered_input(
        &mut self, 
        token: (StreamWriteHandle<K, ()>, StreamReadHandle<K, ()>), 
        as_of_frontier: &Antichain<u64>
    ) -> ((PersistentUnorderedHandle<K>, ActivateCapability<G::Timestamp>), Stream<G, (K, u64, isize)>, Stream<G, (String, u64, isize)>);
}

A persistent equivalent of UnorderedInput.

Required methods

fn new_persistent_unordered_input(
    &mut self,
    token: (StreamWriteHandle<K, ()>, StreamReadHandle<K, ()>),
    as_of_frontier: &Antichain<u64>
) -> ((PersistentUnorderedHandle<K>, ActivateCapability<G::Timestamp>), Stream<G, (K, u64, isize)>, Stream<G, (String, u64, isize)>)

A persistent equivalent of UnorderedInput::new_unordered_input.

Implementors

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