build_dag
collect_columns
Recursively extract referenced Columns within a PhysicalExpr.
convert_to_expr
This function returns all Arc<dyn PhysicalExpr>s inside the given PhysicalSortExpr sequence.
get_indices_of_exprs_strict
This function finds the indices of targets within items using strict equality.
map_columns_before_projection
This function maps back requirement after ProjectionExec to the Executor for its input.
merge_vectors
Merge left and right sort expressions, checking for duplicates.
reassign_predicate_columns
Re-assign column indices referenced in predicate according to given schema. This may be helpful when dealing with projections.
reverse_order_bys
Reverses the ORDER BY expression, which is useful during equivalent window expression construction. For instance, ‘ORDER BY a ASC, NULLS LAST’ turns into ‘ORDER BY a DESC, NULLS FIRST’.
scatter
Scatter truthy array by boolean mask. When the mask evaluates true, next values of truthy are taken, when the mask evaluates false values null values are filled.
split_conjunction
Assume the predicate is in the form of CNF, split the predicate to a Vec of PhysicalExprs.

Module datafusion_physical_expr::utils

Structs