Expand description

Defines physical expressions that can evaluated at runtime during query execution

Re-exports

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

Modules

Module with some convenient methods used in expression building

Structs

APPROX_DISTINCT aggregate expression

MEDIAN aggregate expression

APPROX_PERCENTILE_CONT aggregate expression

APPROX_PERCENTILE_CONT_WITH_WEIGTH aggregate expression

ARRAY_AGG aggregate expression

AVG aggregate expression

An accumulator to compute the average

Binary expression

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.

CAST expression casts an expression to a specific data type and returns a runtime error on invalid cast

Represents the column at a given index in a RecordBatch

CORR aggregate expression

COUNT aggregate expression Returns the amount of non-null values of the given expression.

COVAR and COVAR_SAMP aggregate expression

COVAR_POP aggregate expression

Perform DATE/TIME/TIMESTAMP +/ INTERVAL math

Expression for a ARRAY_AGG(DISTINCT) aggregation.

Expression for a COUNT(DISTINCT) aggregation.

Expression for a SUM(DISTINCT) aggregation.

expression to get a field of a struct array.

GROUPING aggregate expression Returns the amount of non-null values of the given expression.

InList

IS NOT NULL expression

IS NULL expression

Represents a literal value

MAX aggregate expression

An accumulator to compute the maximum value

MEDIAN aggregate expression. This uses a lot of memory because all values need to be stored in memory before a result can be computed. If an approximation is sufficient then APPROX_MEDIAN provides a much more efficient solution.

MIN aggregate expression

An accumulator to compute the minimum value

Negative expression

Not expression

nth_value expression

Represents Sort operation for a column in a RecordBatch

row_number expression

STDDEV and STDDEV_SAMP (standard deviation) aggregate expression

STDDEV_POP population aggregate expression

SUM aggregate expression

TRY_CAST expression casts an expression to a specific data type and retuns NULL on invalid cast

VAR and VAR_SAMP aggregate expression

VAR_POP aggregate expression

Enums

Enum used for differenciating population and sample for statistical functions

Constants

provide DataFusion default cast options

Functions

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.

Create a CASE expression

Return a PhysicalExpression representing expr casted to cast_type, if any casting is needed.

Internal cast function for casting ColumnarValue -> ColumnarValue for cast_type

Return a PhysicalExpression representing expr casted to cast_type, if any casting is needed.

Create a column expression

Create a cume_dist window function

Create a dense rank window function

returns the name of the state

Creates a unary expression InList

Create an IS NOT NULL expression

Create an IS NULL expression

lag() window function

lead() window function

Create a literal expression

Creates a unary expression NEGATIVE

Creates a unary expression NOT

Implements NULLIF(expr1, expr2) Args: 0 - left expr is any array 1 - if the left is equal to this expr2, then the result is NULL, otherwise left value is passed.

Create a percent rank window function

Create a rank window function

Return a PhysicalExpression representing expr casted to cast_type, if any casting is needed.