Trait MaybeBucketByTime 

pub trait MaybeBucketByTime: Timestamp {
    // Required method
    fn maybe_apply_temporal_bucketing<'scope, D>(
        stream: StreamVec<'scope, Self, (D, Self, Diff)>,
        as_of: Antichain<Timestamp>,
        summary: Timestamp,
    ) -> VecCollection<'scope, Self, D, Diff>
       where D: ExchangeData + MzData + Hashable;
}

Apply temporal bucketing to a stream when the timestamp type supports it.

Sibling to RenderTimestamp: bucketing is an arrangement-time concern, not a general property of a render timestamp, so the dispatch lives in its own trait. Total-ordered timestamps perform real bucketing; partially-ordered timestamps (e.g. Product<…> in iterative scopes) implement this as a no-op.

Required Methods

fn maybe_apply_temporal_bucketing<'scope, D>( stream: StreamVec<'scope, Self, (D, Self, Diff)>, as_of: Antichain<Timestamp>, summary: Timestamp, ) -> VecCollection<'scope, Self, D, Diff>

where D: ExchangeData + MzData + Hashable,

Dyn Compatibility

This trait is not dyn compatible.

In older versions of Rust, dyn compatibility was called "object safety".

Implementations on Foreign Types

impl MaybeBucketByTime for Product<Timestamp, PointStamp<u64>>

fn maybe_apply_temporal_bucketing<'scope, D>( stream: StreamVec<'scope, Self, (D, Self, Diff)>, _as_of: Antichain<Timestamp>, _summary: Timestamp, ) -> VecCollection<'scope, Self, D, Diff>

where D: ExchangeData + MzData + Hashable,

impl MaybeBucketByTime for Timestamp

fn maybe_apply_temporal_bucketing<'scope, D>( stream: StreamVec<'scope, Self, (D, Self, Diff)>, as_of: Antichain<Timestamp>, summary: Timestamp, ) -> VecCollection<'scope, Self, D, Diff>

where D: ExchangeData + MzData + Hashable,

Implementors