pub type StackedCollection<G, T> = Collection<G, T, Diff, TimelyStack<(T, <G as ScopeParent>::Timestamp, Diff)>>;
Aliased Type§
pub struct StackedCollection<G, T> {
pub inner: StreamCore<G, TimelyStack<(T, <G as ScopeParent>::Timestamp, Overflowing<i64>)>>,
/* private fields */
}
Fields§
§inner: StreamCore<G, TimelyStack<(T, <G as ScopeParent>::Timestamp, Overflowing<i64>)>>
The underlying timely dataflow stream.
This field is exposed to support direct timely dataflow manipulation when required, but it is not intended to be the idiomatic way to work with the collection.
The timestamp in the data is required to always be at least the timestamp of the data, in the timely-dataflow sense. If this invariant is not upheld, differential operators may behave unexpectedly.