Crate datafusion_physical_expr

Re-exports

• pub use aggregate::AggregateExpr;
• pub use analysis::analyze;
• pub use analysis::AnalysisContext;
• pub use analysis::ExprBoundaries;
• pub use equivalence::ordering_equivalence_properties_helper;
• pub use equivalence::project_equivalence_properties;
• pub use equivalence::project_ordering_equivalence_properties;
• pub use equivalence::EquivalenceProperties;
• pub use equivalence::EquivalentClass;
• pub use equivalence::OrderingEquivalenceProperties;
• pub use equivalence::OrderingEquivalentClass;
• pub use planner::create_physical_expr;
• pub use sort_properties::update_ordering;
• pub use utils::expr_list_eq_any_order;
• pub use utils::expr_list_eq_strict_order;
• pub use utils::find_orderings_of_exprs;
• pub use utils::normalize_expr_with_equivalence_properties;
• pub use utils::normalize_ordering_equivalence_classes;
• pub use utils::normalize_out_expr_with_columns_map;
• pub use utils::reverse_order_bys;
• pub use utils::split_conjunction;

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.
• hash_utils
  Functionality used both on logical and physical plans
• 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

• 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
  Distribution schemes
• EmitTo
  Describes how many rows should be emitted during grouping.
• Partitioning
  Partitioning schemes supported by operators.

Traits

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

Type Aliases

• LexOrdering
  LexOrdering is a type alias for lexicographical ordering definitionVec<PhysicalSortExpr>
• LexOrderingRef
  LexOrderingRef is a type alias for lexicographical ordering reference &[PhysicalSortExpr]
• LexOrderingReq
  LexOrderingReq is a type alias for lexicographical ordering requirement definitionVec<PhysicalSortRequirement>
• PhysicalExprRef
  Shared PhysicalExpr.