Module physical_expr

re-export of datafusion_physical_expr crate

Modules

• aggregate
• analysis
  Interval and selectivity in AnalysisContext
• binary_map
• equivalence
• execution_props
• expressions
  Defines physical expressions that can evaluated at runtime during query execution
• functions
  Deprecated module. Add new feature in scalar_function.rs
• intervals
  Interval arithmetic and constraint propagation library
• math_expressions
  Math expressions
• planner
• tree_node
• udf
• utils
• window

Structs

• AnalysisContext
  The shared context used during the analysis of an expression. Includes the boundaries for all known columns.
• ConstExpr
  A structure representing a expression known to be constant in a physical execution plan.
• EquivalenceProperties
  A EquivalenceProperties object stores useful information related to a schema. Currently, it keeps track of:
• ExprBoundaries
  Represents the boundaries (e.g. min and max values) of a particular column
• GroupsAccumulatorAdapter
  An adapter that implements GroupsAccumulator for any Accumulator
• NullState
  Track the accumulator null state per row: if any values for that group were null and if any values have been seen at all for that group.
• PhysicalSortExpr
  Represents Sort operation for a column in a RecordBatch
• PhysicalSortRequirement
  Represents sort requirement associated with a plan
• ScalarFunctionExpr
  Physical expression of a scalar function

Enums

• Distribution
  How data is distributed amongst partitions. See Partitioning for more details.
• Partitioning
  Output partitioning supported by ExecutionPlans.

Traits

• PhysicalExpr
  PhysicalExprs represent expressions such as A + 1 or CAST(c1 AS int).

Functions

• analyze
  Attempts to refine column boundaries and compute a selectivity value.
• calculate_union
  Calculates the union (in the sense of UnionExec) EquivalenceProperties of the given EquivalenceProperties in eqps according to the given output schema (which need not be the same with those of lhs and rhs as details such as nullability may be different).
• create_physical_expr
  PhysicalExpr evaluate DataFusion expressions such as A + 1, or CAST(c1 AS int).
• create_physical_exprs
  Create vector of Physical Expression from a vector of logical expression
• physical_exprs_bag_equal
  Checks whether the given physical expression slices are equal in the sense of bags (multi-sets), disregarding their orderings.
• physical_exprs_contains
  This function is similar to the contains method of Vec. It finds whether expr is among physical_exprs.
• physical_exprs_equal
  Checks whether the given physical expression slices are equal.
• 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’.
• split_conjunction
  Assume the predicate is in the form of CNF, split the predicate to a Vec of PhysicalExprs.

Type Aliases

• LexOrdering
  LexOrdering is an alias for the type Vec<PhysicalSortExpr>, which represents a lexicographical ordering.
• LexOrderingRef
  LexOrderingRef is an alias for the type &[PhysicalSortExpr], which represents a reference to a lexicographical ordering.
• LexRequirement
  LexRequirement is an alias for the type Vec<PhysicalSortRequirement>, which represents a lexicographical ordering requirement.
• LexRequirementRef
  LexRequirementRef is an alias for the type &[PhysicalSortRequirement], which represents a reference to a lexicographical ordering requirement.
• PhysicalExprRef
  Shared PhysicalExpr.