Enum dataflow::render::join::linear_join::JoinedFlavor [−][src]
enum JoinedFlavor<G, T> where
G: Scope,
G::Timestamp: Lattice + Refines<T>,
T: Timestamp + Lattice, {
Collection(Collection<G, Row, Diff>),
Local(Arranged<G, TraceAgent<OrdValSpine<Row, Row, <G as ScopeParent>::Timestamp, Diff, usize>>>),
Trace(Arranged<G, TraceEnter<TraceFrontier<TraceAgent<OrdValSpine<Row, Row, T, Diff, usize>>>, <G as ScopeParent>::Timestamp>>),
}
Expand description
Different forms the streamed data might take.
Variants
Collection(Collection<G, Row, Diff>)
Tuple Fields
0: Collection<G, Row, Diff>
Streamed data as a collection.
Local(Arranged<G, TraceAgent<OrdValSpine<Row, Row, <G as ScopeParent>::Timestamp, Diff, usize>>>)
Tuple Fields
0: Arranged<G, TraceAgent<OrdValSpine<Row, Row, <G as ScopeParent>::Timestamp, Diff, usize>>>
A dataflow-local arrangement.
Trace(Arranged<G, TraceEnter<TraceFrontier<TraceAgent<OrdValSpine<Row, Row, T, Diff, usize>>>, <G as ScopeParent>::Timestamp>>)
Tuple Fields
0: Arranged<G, TraceEnter<TraceFrontier<TraceAgent<OrdValSpine<Row, Row, T, Diff, usize>>>, <G as ScopeParent>::Timestamp>>
An imported arrangement.
Auto Trait Implementations
impl<G, T> !RefUnwindSafe for JoinedFlavor<G, T>
impl<G, T> !Send for JoinedFlavor<G, T>
impl<G, T> !Sync for JoinedFlavor<G, T>
impl<G, T> Unpin for JoinedFlavor<G, T> where
G: Unpin,
T: Unpin,
<G as ScopeParent>::Timestamp: Unpin,
impl<G, T> !UnwindSafe for JoinedFlavor<G, T>
Blanket Implementations
Mutably borrows from an owned value. Read more
Attaches the provided Subscriber
to this type, returning a
WithDispatch
wrapper. Read more
Attaches the current default Subscriber
to this type, returning a
WithDispatch
wrapper. Read more