Struct HashJoinExecBuilder 

pub struct HashJoinExecBuilder { /* private fields */ }

Helps to build HashJoinExec.

Builder can be created from an existing HashJoinExec using From::from. In this case, all its fields are inherited. If a field that affects the node’s properties is modified, they will be automatically recomputed during the build.

Adding setters

When adding a new setter, it is necessary to ensure that the preserve_properties flag is set to false if modifying the field requires a recomputation of the plan’s properties.

Implementations

impl HashJoinExecBuilder

pub fn new( left: Arc<dyn ExecutionPlan>, right: Arc<dyn ExecutionPlan>, on: Vec<(PhysicalExprRef, PhysicalExprRef)>, join_type: JoinType, ) -> Self

Make a new HashJoinExecBuilder.

pub fn with_type(self, join_type: JoinType) -> Self

Set join type.

pub fn with_projection(self, projection: Option<Vec<usize>>) -> Self

Set projection from the vector.

pub fn with_projection_ref(self, projection: Option<ProjectionRef>) -> Self

Set projection from the shared reference.

pub fn with_filter(self, filter: Option<JoinFilter>) -> Self

Set optional filter.

pub fn with_on(self, on: Vec<(PhysicalExprRef, PhysicalExprRef)>) -> Self

Set expressions to join on.

pub fn with_partition_mode(self, mode: PartitionMode) -> Self

Set partition mode.

pub fn with_null_equality(self, null_equality: NullEquality) -> Self

Set null equality property.

pub fn with_null_aware(self, null_aware: bool) -> Self

Set null aware property.

pub fn with_fetch(self, fetch: Option<usize>) -> Self

Set fetch property.

pub fn recompute_properties(self) -> Self

Require to recompute plan properties.

pub fn with_new_children( self, children: Vec<Arc<dyn ExecutionPlan>>, ) -> Result<Self>

Replace children.

pub fn reset_state(self) -> Self

Reset runtime state.

pub fn build_exec(self) -> Result<Arc<dyn ExecutionPlan>>

Build result as a dyn execution plan.

pub fn build(self) -> Result<HashJoinExec>

Build resulting execution plan.

Trait Implementations

impl From<&HashJoinExec> for HashJoinExecBuilder

fn from(exec: &HashJoinExec) -> Self

Converts to this type from the input type.