Struct datafusion_physical_plan::joins::utils::JoinFilter

pub struct JoinFilter { /* private fields */ }

Filter applied before join output

Implementations

impl JoinFilter

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

Intermediate batch schema

Trait Implementations

impl Clone for JoinFilter

fn clone(&self) -> JoinFilter

Returns a copy 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.