Enum expr::JoinImplementation

pub enum JoinImplementation {
    Differential((usize, Option<Vec<MirScalarExpr>>), Vec<(usize, Vec<MirScalarExpr>)>),
    DeltaQuery(Vec<Vec<(usize, Vec<MirScalarExpr>)>>),
    Unimplemented,
}

Describe a join implementation in dataflow.

Variants

Differential((usize, Option<Vec<MirScalarExpr>>), Vec<(usize, Vec<MirScalarExpr>)>)

Tuple Fields

0: (usize, Option<Vec<MirScalarExpr>>)

1: 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>)>>)

Tuple Fields

0: 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

impl Clone for JoinImplementation

fn clone(&self) -> JoinImplementation

Returns a copy of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.

impl Debug for JoinImplementation

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.

impl Default for JoinImplementation

fn default() -> Self

Returns the “default value” for a type.

impl<'de> Deserialize<'de> for JoinImplementation

fn deserialize<__D>(__deserializer: __D) -> Result<Self, __D::Error> where
    __D: Deserializer<'de>, 

Deserialize this value from the given Serde deserializer.

impl Hash for JoinImplementation

fn hash<__H: Hasher>(&self, state: &mut __H)

Feeds this value into the given Hasher.

fn hash_slice<H>(data: &[Self], state: &mut H) where
    H: Hasher, 

Feeds a slice of this type into the given Hasher.

impl MzReflect for JoinImplementation

fn add_to_reflected_type_info(rti: &mut ReflectedTypeInfo)

Adds names and types of the fields of the struct or enum to rti.

impl PartialEq<JoinImplementation> for JoinImplementation

fn eq(&self, other: &JoinImplementation) -> bool

This method tests for self and other values to be equal, and is used by ==.

fn ne(&self, other: &JoinImplementation) -> bool

This method tests for !=.

impl Serialize for JoinImplementation

fn serialize<__S>(&self, __serializer: __S) -> Result<__S::Ok, __S::Error> where
    __S: Serializer, 

Serialize this value into the given Serde serializer.

impl Eq for JoinImplementation

impl StructuralEq for JoinImplementation

impl StructuralPartialEq for JoinImplementation