Crate datafusion_physical_expr

Re-exports

pub use analysis::analyze;

pub use analysis::AnalysisContext;

pub use analysis::ExprBoundaries;

pub use equivalence::calculate_union;

pub use equivalence::AcrossPartitions;

pub use equivalence::ConstExpr;

pub use equivalence::EquivalenceProperties;

pub use planner::create_physical_expr;

pub use planner::create_physical_exprs;

pub use utils::split_conjunction;

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

tree_node

udf

utils

window

Structs

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

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

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

Type Aliases

PhysicalExprRef

Shared PhysicalExpr.