minimize_join_filter

datafusion_physical_optimizer::projection_pushdown

Function minimize_join_filter 

Source 
fn minimize_join_filter(
    expr: Arc<dyn PhysicalExpr>,
    old_column_indices: Vec<ColumnIndex>,
    lhs_schema: &Schema,
    rhs_schema: &Schema,
) -> JoinFilter
Expand description

Creates a new JoinFilter and tries to minimize the internal schema.

This could eliminate some columns that were only part of a computation that has been pushed down. As this computation is now materialized on one side of the join, the original input columns are not needed anymore.