Struct 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 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 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.