Trait persist::operators::stream::RetractUnsealed

pub trait RetractUnsealed<G: Scope<Timestamp = u64>, K: TimelyData, V: TimelyData> {
    fn retract_unsealed(
        &self, 
        name: &str, 
        write: StreamWriteHandle<K, V>, 
        upper_ts: u64
    ) -> (Stream<G, ((K, V), u64, isize)>, Stream<G, (String, u64, isize)>);
}

Extension trait for Stream.

Required methods

fn retract_unsealed(
    &self,
    name: &str,
    write: StreamWriteHandle<K, V>,
    upper_ts: u64
) -> (Stream<G, ((K, V), u64, isize)>, Stream<G, (String, u64, isize)>)

Passes through each element of the stream and sends retractions to the given StreamWriteHandle for updates that are beyond the given upper_ts. In practice, the upper_ts is the lowest timestamp that is sealed across all persisted streams for a source.

This does not wait for retractions to be persisted before passing through the data. We do, however, wait for data to be persisted before allowing the frontier to advance. In other words, this operator is holding on to capabilities as long as retractions belonging to their timestamp is not persisted.

Implementations on Foreign Types

impl<G, K, V> RetractUnsealed<G, K, V> for Stream<G, ((K, V), u64, isize)> where
    G: Scope<Timestamp = u64>,
    K: TimelyData + Codec + Debug,
    V: TimelyData + Codec + Debug, 

fn retract_unsealed(
    &self,
    name: &str,
    write: StreamWriteHandle<K, V>,
    upper_ts: u64
) -> (Stream<G, ((K, V), u64, isize)>, Stream<G, (String, u64, isize)>)

Implementors