Struct dataflow_types::plan::join::delta_join::DeltaJoinPlan [−][src]
pub struct DeltaJoinPlan {
pub path_plans: Vec<DeltaPathPlan>,
}
Expand description
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
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>)
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
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
Auto Trait Implementations
impl RefUnwindSafe for DeltaJoinPlan
impl Send for DeltaJoinPlan
impl Sync for DeltaJoinPlan
impl Unpin for DeltaJoinPlan
impl UnwindSafe for DeltaJoinPlan
Blanket Implementations
Mutably borrows from an owned value. Read more
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