Enum expr::relation::JoinImplementation [−][src]
pub enum JoinImplementation {
Differential((usize, Option<Vec<MirScalarExpr>>), Vec<(usize, Vec<MirScalarExpr>)>),
DeltaQuery(Vec<Vec<(usize, Vec<MirScalarExpr>)>>),
Unimplemented,
}
Expand description
Describe a join implementation in dataflow.
Variants
Differential((usize, Option<Vec<MirScalarExpr>>), Vec<(usize, Vec<MirScalarExpr>)>)
Perform a sequence of binary differential dataflow joins.
The first argument indicates 1) the index of the starting collection and 2) if it should be arranged, the keys to arrange it by. The sequence that follows lists other relation indexes, and the key for the arrangement we should use when joining it in.
Each collection index should occur exactly once, either in the first position or somewhere in the list.
DeltaQuery(Vec<Vec<(usize, Vec<MirScalarExpr>)>>)
Perform independent delta query dataflows for each input.
The argument is a sequence of plans, for the input collections in order. Each plan starts from the corresponding index, and then in sequence joins against collections identified by index and with the specified arrangement key.
Unimplemented
No implementation yet selected.
Trait Implementations
fn deserialize<__D>(__deserializer: __D) -> Result<Self, __D::Error> where
__D: Deserializer<'de>,
fn deserialize<__D>(__deserializer: __D) -> Result<Self, __D::Error> where
__D: Deserializer<'de>,
Deserialize this value from the given Serde deserializer. Read more
Adds names and types of the fields of the struct or enum to rti
. Read more
This method tests for self
and other
values to be equal, and is used
by ==
. Read more
This method tests for !=
.
Auto Trait Implementations
impl RefUnwindSafe for JoinImplementation
impl Send for JoinImplementation
impl Sync for JoinImplementation
impl Unpin for JoinImplementation
impl UnwindSafe for JoinImplementation
Blanket Implementations
Mutably borrows from an owned value. Read more
Compare self to key
and return true
if they are equal.
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