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 schema_rewriter::DefaultPhysicalExprAdapter;

pub use utils::conjunction;

pub use utils::conjunction_opt;

pub use utils::split_conjunction;

Modules

aggregate

analysis

Interval and selectivity in AnalysisContext

async_scalar_function

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

schema_rewriter

Physical expression schema rewriting utilities

simplifier

Simplifier for Physical Expressions

statistics

Statistics and constraint propagation library

tree_node

utils

window

Structs

GroupsAccumulatorAdapter

An adapter that implements GroupsAccumulator for any Accumulator

LexOrdering

This object represents a lexicographical ordering and contains a vector of PhysicalSortExpr objects.

LexRequirement

This object represents a lexicographical ordering requirement and contains a vector of PhysicalSortRequirement objects.

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.

OrderingRequirements

Represents a plan’s input ordering requirements. Vector elements represent alternative ordering requirements in the order of preference. The list of alternatives can be either hard or soft, depending on whether the operator can work without an input ordering.

Partitioning

Output partitioning supported by ExecutionPlans.

Traits

PhysicalExpr

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

Functions

add_offset_to_expr

Adds the offset value to Column indices inside expr. This function is generally used during the update of the right table schema in join operations.

add_offset_to_physical_sort_exprs

create_ordering

Converts logical sort expressions to physical sort expressions.

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.

Type Aliases

PhysicalExprRef

Shared PhysicalExpr.