Trait persist::operators::stream::Seal [−][src]
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)>;
}
Expand description
Extension trait for Stream
.
Required methods
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.