Enum mz_compute::render::reduce::ArrangementOrCollection
source · enum ArrangementOrCollection<G>where
G: Scope,
G::Timestamp: Lattice,{
Arrangement(Arranged<G, TraceAgent<ColValSpine<Row, Row, <G as ScopeParent>::Timestamp, Diff, usize>>>),
Collection(Collection<G, Row, Diff>),
}
Expand description
A type wrapping either an arrangement or a single collection.
Variants§
Arrangement(Arranged<G, TraceAgent<ColValSpine<Row, Row, <G as ScopeParent>::Timestamp, Diff, usize>>>)
Wrap an arrangement
Collection(Collection<G, Row, Diff>)
Wrap a collection
Implementations§
source§impl<G> ArrangementOrCollection<G>where
G: Scope,
G::Timestamp: Lattice,
impl<G> ArrangementOrCollection<G>where
G: Scope,
G::Timestamp: Lattice,
sourcefn into_bundle<T>(
self,
key_arity: usize,
err_input: Collection<G, DataflowError, Diff>
) -> CollectionBundle<G, Row, T>where
G::Timestamp: Lattice + Refines<T>,
T: Timestamp + Lattice,
fn into_bundle<T>(
self,
key_arity: usize,
err_input: Collection<G, DataflowError, Diff>
) -> CollectionBundle<G, Row, T>where
G::Timestamp: Lattice + Refines<T>,
T: Timestamp + Lattice,
Convert to a CollectionBundle by either supplying the arrangement or construction from collections.
key_arity
- The number of columns in the key. Only used for arrangement variants.err_input
- A collection containing the error stream.
Trait Implementations§
source§impl<G> From<Arranged<G, TraceAgent<Spine<Rc<OrdValBatch<Row, Row, <G as ScopeParent>::Timestamp, i64, usize, TimelyStack<Row>, TimelyStack<Row>>>>>>> for ArrangementOrCollection<G>where
G: Scope,
G::Timestamp: Lattice,
impl<G> From<Arranged<G, TraceAgent<Spine<Rc<OrdValBatch<Row, Row, <G as ScopeParent>::Timestamp, i64, usize, TimelyStack<Row>, TimelyStack<Row>>>>>>> for ArrangementOrCollection<G>where
G: Scope,
G::Timestamp: Lattice,
source§fn from(
arrangement: Arranged<G, TraceAgent<ColValSpine<Row, Row, <G as ScopeParent>::Timestamp, Diff, usize>>>
) -> Self
fn from(
arrangement: Arranged<G, TraceAgent<ColValSpine<Row, Row, <G as ScopeParent>::Timestamp, Diff, usize>>>
) -> Self
Converts to this type from the input type.
Auto Trait Implementations§
impl<G> !RefUnwindSafe for ArrangementOrCollection<G>
impl<G> !Send for ArrangementOrCollection<G>
impl<G> !Sync for ArrangementOrCollection<G>
impl<G> Unpin for ArrangementOrCollection<G>where
G: Unpin,
<G as ScopeParent>::Timestamp: Unpin,
impl<G> !UnwindSafe for ArrangementOrCollection<G>
Blanket Implementations§
source§impl<T> FutureExt for T
impl<T> FutureExt for T
source§fn with_context(self, otel_cx: Context) -> WithContext<Self>
fn with_context(self, otel_cx: Context) -> WithContext<Self>
source§fn with_current_context(self) -> WithContext<Self>
fn with_current_context(self) -> WithContext<Self>
source§impl<T> Instrument for T
impl<T> Instrument for T
source§fn instrument(self, span: Span) -> Instrumented<Self>
fn instrument(self, span: Span) -> Instrumented<Self>
source§fn in_current_span(self) -> Instrumented<Self>
fn in_current_span(self) -> Instrumented<Self>
source§impl<T> IntoRequest<T> for T
impl<T> IntoRequest<T> for T
source§fn into_request(self) -> Request<T>
fn into_request(self) -> Request<T>
Wrap the input message
T
in a tonic::Request
source§impl<T> Pointable for T
impl<T> Pointable for T
source§impl<P, R> ProtoType<R> for Pwhere
R: RustType<P>,
impl<P, R> ProtoType<R> for Pwhere
R: RustType<P>,
source§fn into_rust(self) -> Result<R, TryFromProtoError>
fn into_rust(self) -> Result<R, TryFromProtoError>
See
RustType::from_proto
.source§fn from_rust(rust: &R) -> P
fn from_rust(rust: &R) -> P
See
RustType::into_proto
.