Module datafusion_physical_expr::expressions

Defines physical expressions that can evaluated at runtime during query execution

Re-exports

• pub use crate::aggregate::build_in::create_aggregate_expr;

Modules

• helpers
  Module with some convenient methods used in expression building

Structs

• ArrayAgg
  ARRAY_AGG aggregate expression
• BinaryExpr
  Binary expression
• CaseExpr
  The CASE expression is similar to a series of nested if/else and there are two forms that can be used. The first form consists of a series of boolean “when” expressions with corresponding “then” expressions, and an optional “else” expression.
• CastExpr
  CAST expression casts an expression to a specific data type and returns a runtime error on invalid cast
• Column
  Represents the column at a given index in a RecordBatch
• CumeDist
  CumeDist calculates the cume_dist in the window function with order by
• DistinctArrayAgg
  Expression for a ARRAY_AGG(DISTINCT) aggregation.
• InListExpr
  InList
• IsNotNullExpr
  IS NOT NULL expression
• IsNullExpr
  IS NULL expression
• LikeExpr
• Literal
  Represents a literal value
• Max
  MAX aggregate expression
• MaxAccumulator
  An accumulator to compute the maximum value
• Min
  MIN aggregate expression
• MinAccumulator
  An accumulator to compute the minimum value
• NegativeExpr
  Negative expression
• NoOp
  A place holder expression, can not be evaluated.
• NotExpr
  Not expression
• NthValue
  nth_value expression
• Ntile
• OrderSensitiveArrayAgg
  Expression for a ARRAY_AGG(... ORDER BY ..., ...) aggregation. In a multi partition setting, partial aggregations are computed for every partition, and then their results are merged.
• PhysicalSortExpr
  Represents Sort operation for a column in a RecordBatch
• Rank
  Rank calculates the rank in the window function with order by
• RowNumber
  row_number expression
• TryCastExpr
  TRY_CAST expression casts an expression to a specific data type and retuns NULL on invalid cast
• UnKnownColumn
• WindowShift
  window shift expression

Enums

• RankType
• StatsType
  TODO: Move this to functions-aggregate module Enum used for differentiating population and sample for statistical functions

Functions

• binary
  Create a binary expression whose arguments are correctly coerced. This function errors if it is not possible to coerce the arguments to computational types supported by the operator.
• case
  Create a CASE expression
• cast
  Return a PhysicalExpression representing expr casted to cast_type, if any casting is needed.
• col
  Create a column expression
• cume_dist
  Create a cume_dist window function
• dense_rank
  Create a dense rank window function
• format_state_name
  Build state name. State is the intermidiate state of the aggregate function.
• in_list
  Creates a unary expression InList
• is_not_null
  Create an IS NOT NULL expression
• is_null
  Create an IS NULL expression
• lag
  lag() window function
• lead
  lead() window function
• like
  Create a like expression, erroring if the argument types are not compatible.
• lit
  Create a literal expression
• negative
  Creates a unary expression NEGATIVE
• not
  Creates a unary expression NOT
• percent_rank
  Create a percent rank window function
• rank
  Create a rank window function
• try_cast
  Return a PhysicalExpression representing expr casted to cast_type, if any casting is needed.