Trait persist::operators::stream::Seal

pub trait Seal<G: Scope<Timestamp = u64>, D: TimelyData> {
    fn seal(
        &self, 
        name: &str, 
        additional_frontiers: Vec<ProbeHandle<u64>>, 
        write: MultiWriteHandle
    ) -> Stream<G, (D, u64, isize)>;
}

Extension trait for Stream.

Required methods

fn seal(
    &self,
    name: &str,
    additional_frontiers: Vec<ProbeHandle<u64>>,
    write: MultiWriteHandle
) -> Stream<G, (D, u64, isize)>

Passes through each element of the stream and calls seal_all on the given MultiWriteHandle when the combined input frontier advances advances. The combined input frontier is derived by combining the frontier of the input with the optional ProbeHandles.

This does not wait for the seal to succeed before passing through the data. We do, however, wait for the seal to be successful before allowing the frontier to advance. In other words, this operator is holding on to capabilities as long as seals corresponding to their timestamp are not done.

Implementations on Foreign Types

impl<G, D> Seal<G, D> for Stream<G, (D, u64, isize)> where
    G: Scope<Timestamp = u64>,
    D: TimelyData, 

fn seal(
    &self,
    name: &str,
    additional_frontiers: Vec<ProbeHandle<u64>>,
    write: MultiWriteHandle
) -> Stream<G, (D, u64, isize)>

Implementors