Struct mz_dataflow_types::plan::join::delta_join::DeltaJoinPlan

pub struct DeltaJoinPlan {
    pub path_plans: Vec<DeltaPathPlan>,
}

A delta query is implemented by a set of paths, one for each input.

Each delta query path responds to its input changes by repeated lookups in arrangements for other join inputs. These lookups require specific instructions about which expressions to use as keys. Along the way, various closures are applied to filter and project as early as possible.

Fields

path_plans: Vec<DeltaPathPlan>

The set of path plans.

Each path identifies its source relation, so the order is only important for determinism of dataflow construction.

Implementations

impl DeltaJoinPlan

pub fn create_from(
    equivalences: &[Vec<MirScalarExpr>],
    join_orders: &[Vec<(usize, Vec<MirScalarExpr>)>],
    input_mapper: JoinInputMapper,
    map_filter_project: &mut MapFilterProject,
    available: &[AvailableCollections]
) -> (Self, Vec<AvailableCollections>)

Create a new join plan from the required arguments.

Trait Implementations

impl Arbitrary for DeltaJoinPlan

type Parameters = ()

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

type Strategy = BoxedStrategy<Self>

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

fn arbitrary_with(_: 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 DeltaJoinPlan

fn clone(&self) -> DeltaJoinPlan

Returns a copy of the value.

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

Performs copy-assignment from source.

impl Debug for DeltaJoinPlan

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

Formats the value using the given formatter.

impl<'de> Deserialize<'de> for DeltaJoinPlan

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

Deserialize this value from the given Serde deserializer.

impl PartialEq<DeltaJoinPlan> for DeltaJoinPlan

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

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

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

This method tests for !=.

impl RustType<ProtoDeltaJoinPlan> for DeltaJoinPlan

fn into_proto(&self) -> ProtoDeltaJoinPlan

Convert a Self into a Proto value.

fn from_proto(proto: ProtoDeltaJoinPlan) -> Result<Self, TryFromProtoError>

Consume and convert a Proto back into a Self value.

impl Serialize for DeltaJoinPlan

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 DeltaJoinPlan

impl StructuralEq for DeltaJoinPlan

impl StructuralPartialEq for DeltaJoinPlan