Trait TemporalBucketing

pub trait TemporalBucketing<G: Scope, O> {
    // Required method
    fn bucket<CB>(
        &self,
        as_of: Antichain<G::Timestamp>,
        threshold: <G::Timestamp as Timestamp>::Summary,
    ) -> StreamCore<G, CB::Container>
       where CB: ContainerBuilder + PushInto<O>;
}

Sort outstanding updates into a BucketChain, and reveal data not in advance of the input frontier. Retains a capability at the last input frontier to retain the right to produce data at times between the last input frontier and the current input frontier.

Required Methods

fn bucket<CB>( &self, as_of: Antichain<G::Timestamp>, threshold: <G::Timestamp as Timestamp>::Summary, ) -> StreamCore<G, CB::Container>

where CB: ContainerBuilder + PushInto<O>,

Construct a new stream that stores updates into a BucketChain and reveals data not in advance of the frontier. Data that is within threshold distance of the input frontier or the as_of is passed through without being stored in the chain.

Dyn Compatibility

This trait is not dyn compatible.

In older versions of Rust, dyn compatibility was called "object safety", so this trait is not object safe.

Implementations on Foreign Types

impl<G, D> TemporalBucketing<G, (D, <G as ScopeParent>::Timestamp, Overflowing<i64>)> for StreamCore<G, Vec<(D, G::Timestamp, Diff)>>

where G: Scope<Timestamp: ExchangeData + MzData + BucketTimestamp + TotalOrder + Lattice>, D: ExchangeData + MzData + Ord + Debug + Hashable,

Implementation for streams in scopes where timestamps define a total order.

fn bucket<CB>( &self, as_of: Antichain<G::Timestamp>, threshold: <G::Timestamp as Timestamp>::Summary, ) -> StreamCore<G, CB::Container>

where CB: ContainerBuilder + PushInto<(D, G::Timestamp, Diff)>,

Implementors