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

intervals

Interval arithmetic and constraint propagation library

planner

statistics

Statistics and constraint propagation library

tree_node

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

EquivalenceProperties stores information 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

Enums

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.

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).

conjunction

Create a conjunction of the given predicates. If the input is empty, return a literal true. If the input contains a single predicate, return the predicate. Otherwise, return a conjunction of the predicates (e.g. a AND b AND c).

conjunction_opt

Create a conjunction of the given predicates. If the input is empty or the return None. If the input contains a single predicate, return Some(predicate). Otherwise, return a Some(..) of a conjunction of the predicates (e.g. Some(a AND b AND c)).

create_ordering

Converts logical sort expressions to physical sort expressions

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

create_physical_sort_expr

Create a physical sort expression from a logical expression

create_physical_sort_exprs

Create vector of physical sort 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

PhysicalExprRef

Shared PhysicalExpr.