Struct dataflow::render::join::linear_join::LinearJoinPlan [−][src]
pub struct LinearJoinPlan {
source_relation: usize,
initial_closure: Option<JoinClosure>,
stage_plans: Vec<LinearStagePlan>,
final_closure: Option<JoinClosure>,
}
Fields
source_relation: usize
The source relation from which we start the join.
initial_closure: Option<JoinClosure>
An initial closure to apply before any stages.
Values of None
indicate the identity closure.
stage_plans: Vec<LinearStagePlan>
A sequence of stages to apply one after the other.
final_closure: Option<JoinClosure>
A concluding closure to apply after the last stage.
Values of None
indicate the identity closure.
Implementations
pub fn create_from(
source_relation: usize,
equivalences: &[Vec<MirScalarExpr>],
join_order: &[(usize, Vec<MirScalarExpr>)],
input_mapper: JoinInputMapper,
map_filter_project: &mut MapFilterProject
) -> Self
pub fn create_from(
source_relation: usize,
equivalences: &[Vec<MirScalarExpr>],
join_order: &[(usize, Vec<MirScalarExpr>)],
input_mapper: JoinInputMapper,
map_filter_project: &mut MapFilterProject
) -> Self
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 LinearJoinPlan
impl Send for LinearJoinPlan
impl Sync for LinearJoinPlan
impl Unpin for LinearJoinPlan
impl UnwindSafe for LinearJoinPlan
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