Module physical_expr

Expand description

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
intervals: Interval arithmetic and constraint propagation library
planner
statistics: Statistics and constraint propagation library
tree_node
udf
utils
window

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 information known about the output of a plan node, that can be used to optimize the plan.
ExprBoundaries: Represents the boundaries (e.g. min and max values) of a particular column
GroupsAccumulatorAdapter: An adapter that implements GroupsAccumulator for any Accumulator
LexOrdering: LexOrdering contains a Vec<PhysicalSortExpr>, which represents a lexicographical ordering.
LexRequirement: LexRequirement is an struct containing a Vec<PhysicalSortRequirement>, which represents a lexicographical ordering requirement.
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

AcrossPartitions: Represents whether a constant expression’s value is uniform or varies across partitions.
Distribution: How data is distributed amongst partitions. See Partitioning for more details.
Partitioning: Output partitioning supported by ExecutionPlans.

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

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.