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>;
}
Expand description
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§
Sourcefn bucket<CB>(
&self,
as_of: Antichain<G::Timestamp>,
threshold: <G::Timestamp as Timestamp>::Summary,
) -> StreamCore<G, CB::Container>where
CB: ContainerBuilder + PushInto<O>,
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§
Source§impl<G, D> TemporalBucketing<G, (D, <G as ScopeParent>::Timestamp, Overflowing<i64>)> for StreamCore<G, Vec<(D, G::Timestamp, Diff)>>
Implementation for streams in scopes where timestamps define a total order.
impl<G, D> TemporalBucketing<G, (D, <G as ScopeParent>::Timestamp, Overflowing<i64>)> for StreamCore<G, Vec<(D, G::Timestamp, Diff)>>
Implementation for streams in scopes where timestamps define a total order.