Module datafusion_physical_expr::utils

Structs

• ExprTreeNode

Functions

• 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.
• expr_list_eq_any_order
  Compare the two expr lists are equal no matter the order. For example two InListExpr can be considered to be equals no matter the order:
• expr_list_eq_strict_order
  Strictly compare the two expr lists are equal in the given order.
• find_orderings_of_exprs
  Calculates the output orderings for a set of expressions within the context of a given execution plan. The resulting orderings are all in the type of Column, since these expressions become Column after the projection step. The expressions having an alias are renamed with those aliases in the returned PhysicalSortExpr’s. If an expression is found to be unordered, the corresponding entry in the output vector is None.
• get_finer_ordering
  Find the finer requirement among req1 and req2 If None, this means that req1 and req2 are not compatible e.g there is no requirement that satisfies both
• get_indices_of_exprs_strict
  This function finds the indices of targets within items using strict equality.
• get_indices_of_matching_exprs
  This function finds the indices of targets within items, taking into account equivalences according to equal_properties.
• get_indices_of_matching_sort_exprs_with_order_eq
  Attempts to find a full match between the required columns to be ordered (lexicographically), and the provided sort options (lexicographically), while considering equivalence properties.
• 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.
• normalize_out_expr_with_columns_map
  Normalize the output expressions based on Columns Map.
• ordering_satisfy
  Checks whether given ordering requirements are satisfied by provided PhysicalSortExprs.
• ordering_satisfy_concrete
  Checks whether the required PhysicalSortExprs are satisfied by the provided PhysicalSortExprs.
• ordering_satisfy_requirement
  Checks whether the given PhysicalSortRequirements are satisfied by the provided PhysicalSortExprs.
• ordering_satisfy_requirement_concrete
  Checks whether the given PhysicalSortRequirements are satisfied by the provided PhysicalSortExprs.
• reassign_predicate_columns
  Re-assign column indices referenced in predicate according to given schema. This may be helpful when dealing with projections.
• requirements_compatible
  Checks whether the given PhysicalSortRequirements are equal or more specific than the provided PhysicalSortRequirements.
• 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.