Module datafusion::physical_expr

re-export of datafusion_physical_expr crate

Modules

• aggregate
• analysis
  Interval and selectivity in AnalysisContext
• array_expressions
  Array expressions
• conditional_expressions
• crypto_expressions
  Crypto expressions
• datetime_expressions
  DateTime expressions
• encoding_expressions
  Encoding expressions
• equivalence
• execution_props
• expressions
  Defines physical expressions that can evaluated at runtime during query execution
• functions
  Declaration of built-in (scalar) functions. This module contains built-in functions’ enumeration and metadata.
• intervals
  Interval arithmetic and constraint propagation library
• math_expressions
  Math expressions
• planner
• regex_expressions
  Regex expressions
• sort_properties
• string_expressions
  String expressions
• struct_expressions
  Struct expressions
• tree_node
  This module provides common traits for visiting or rewriting tree nodes easily.
• udf
  UDF support
• unicode_expressions
  Unicode expressions
• utils
• var_provider
  Variable provider
• window

Structs

• AnalysisContext
  The shared context used during the analysis of an expression. Includes the boundaries for all known columns.
• 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
• 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.
• EmitTo
  Describes how many rows should be emitted during grouping.
• Partitioning
  Output partitioning supported by ExecutionPlans.

Traits

• AggregateExpr
  An aggregate expression that:
• GroupsAccumulator
  GroupAccumulator implements a single aggregate (e.g. AVG) and stores the state for all groups internally.
• PhysicalExpr
  Expression that can be evaluated against a RecordBatch A Physical expression knows its type, nullability and how to evaluate itself.

Functions

• analyze
  Attempts to refine column boundaries and compute a selectivity value.
• create_physical_expr
  Create a physical expression from a logical expression (Expr).
• 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.