Enum mz_expr::relation::JoinImplementation

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

Describe a join implementation in dataflow.

Variants

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

Perform a sequence of binary differential dataflow joins.

The first argument indicates

1. the index of the starting collection,
2. if it should be arranged, the keys to arrange it by, and
3. the characteristics of the starting collection (for EXPLAINing). The sequence that follows lists other relation indexes, and the key for the arrangement we should use when joining it in. The JoinInputCharacteristics are for EXPLAINing the characteristics that were used for join ordering.

Each collection index should occur exactly once, either as the starting collection or somewhere in the list.

DeltaQuery(Vec<Vec<(usize, Vec<MirScalarExpr>, Option<JoinInputCharacteristics>)>>)

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. The JoinInputCharacteristics are for EXPLAINing the characteristics that were used for join ordering.

IndexedFilter(GlobalId, GlobalId, Vec<MirScalarExpr>, Vec<Row>)

Join a user-created index with a constant collection to speed up the evaluation of a predicate such as (f1 = 3 AND f2 = 5) OR (f1 = 7 AND f2 = 9). This gets translated to a Differential join during MIR -> LIR lowering, but we still want to represent it in MIR, because the fast path detection wants to match on this.

Consists of (<coll_id>, <index_id>, <index_key>, <constants>)

Unimplemented

No implementation yet selected.

Implementations

impl JoinImplementation

pub fn is_implemented(&self) -> bool

Returns true iff the value is not JoinImplementation::Unimplemented.

pub fn name(&self) -> Option<&'static str>

Returns an optional implementation name if the value is not JoinImplementation::Unimplemented.

Trait Implementations

impl Arbitrary for JoinImplementation

type Parameters = ((<(usize, Option<Vec<MirScalarExpr>>, Option<JoinInputCharacteristics>) as Arbitrary>::Parameters, <Vec<(usize, Vec<MirScalarExpr>, Option<JoinInputCharacteristics>)> as Arbitrary>::Parameters), <Vec<Vec<(usize, Vec<MirScalarExpr>, Option<JoinInputCharacteristics>)>> as Arbitrary>::Parameters, (<GlobalId as Arbitrary>::Parameters, <GlobalId as Arbitrary>::Parameters, <Vec<MirScalarExpr> as Arbitrary>::Parameters, <Vec<Row> as Arbitrary>::Parameters))

The type of parameters that arbitrary_with accepts for configuration of the generated Strategy. Parameters must implement Default.

type Strategy = Union<BoxedStrategy<JoinImplementation>>

The type of Strategy used to generate values of type Self.

fn arbitrary_with(_top: Self::Parameters) -> Self::Strategy

Generates a Strategy for producing arbitrary values of type the implementing type (Self). The strategy is passed the arguments given in args.

fn arbitrary() -> Self::Strategy

Generates a Strategy for producing arbitrary values of type the implementing type (Self).

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, Self: Sized,

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 Ord for JoinImplementation

fn cmp(&self, other: &JoinImplementation) -> Ordering

This method returns an Ordering between self and other.

fn max(self, other: Self) -> Self

where Self: Sized,

Compares and returns the maximum of two values.

fn min(self, other: Self) -> Self

where Self: Sized,

Compares and returns the minimum of two values.

fn clamp(self, min: Self, max: Self) -> Self

where Self: Sized + PartialOrd,

Restrict a value to a certain interval.

impl PartialEq for JoinImplementation

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

Tests for self and other values to be equal, and is used by ==.

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

Tests for !=. The default implementation is almost always sufficient, and should not be overridden without very good reason.

impl PartialOrd for JoinImplementation

fn partial_cmp(&self, other: &JoinImplementation) -> Option<Ordering>

This method returns an ordering between self and other values if one exists.

fn lt(&self, other: &Rhs) -> bool

Tests less than (for self and other) and is used by the < operator.

fn le(&self, other: &Rhs) -> bool

Tests less than or equal to (for self and other) and is used by the <= operator.

fn gt(&self, other: &Rhs) -> bool

Tests greater than (for self and other) and is used by the > operator.

fn ge(&self, other: &Rhs) -> bool

Tests greater than or equal to (for self and other) and is used by the >= operator.

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 StructuralPartialEq for JoinImplementation