Struct JoinFilter 

pub struct JoinFilter { /* private fields */ }

Filter applied before join output. Fields are crate-public to allow downstream implementations to experiment with custom joins.

Implementations

impl JoinFilter

pub fn new( expression: Arc<dyn PhysicalExpr>, column_indices: Vec<ColumnIndex>, schema: SchemaRef, ) -> JoinFilter

Creates new JoinFilter

pub fn build_column_indices( left_indices: Vec<usize>, right_indices: Vec<usize>, ) -> Vec<ColumnIndex>

Helper for building ColumnIndex vector from left and right indices

pub fn expression(&self) -> &Arc<dyn PhysicalExpr>

Filter expression

pub fn column_indices(&self) -> &[ColumnIndex]

Column indices for intermediate batch creation

pub fn schema(&self) -> &SchemaRef

Intermediate batch schema

pub fn swap(&self) -> JoinFilter

Rewrites the join filter if the inputs to the join are rewritten

Trait Implementations

impl Clone for JoinFilter

fn clone(&self) -> JoinFilter

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for JoinFilter

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

Formats the value using the given formatter.

impl Display for JoinFilter

For display in EXPLAIN plans, only expression with column names is needed, it output expression like (col1 + col2) = 0

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

Formats the value using the given formatter.