Struct JoinFilter 

pub struct JoinFilter {
    pub(crate) expression: Arc<dyn PhysicalExpr>,
    pub(crate) column_indices: Vec<ColumnIndex>,
    pub(crate) schema: Arc<Schema>,
}

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

Fields

expression: Arc<dyn PhysicalExpr>

column_indices: Vec<ColumnIndex>

schema: Arc<Schema>

Implementations

impl JoinFilter

pub fn new( expression: Arc<dyn PhysicalExpr>, column_indices: Vec<ColumnIndex>, schema: Arc<Schema>, ) -> 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) -> &Arc<Schema>

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<(), Error>

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<(), Error>

Formats the value using the given formatter.