Module window_expr 

Structs

WindowPhysicalExpressions

Stores the physical expressions used inside the WindowExpr.

WindowState

Enums

WindowFn

Traits

AggregateWindowExpr

Extension trait that adds common functionality to AggregateWindowExprs

WindowExpr

Common trait for window function implementations

Functions

filter_array 🔒

Filters a single array with the provided boolean mask.

filter_arrays 🔒

Filters a list of arrays with the provided boolean mask.

get_orderby_values 🔒

Get order by expression results inside order_by_columns.

is_end_bound_safe 🔒

Determines whether the end bound calculation for a window frame context is safe, meaning that the end bound stays the same, regardless of future data, based on the current sort expressions and ORDER BY columns. This function delegates work to specific functions for each frame type.

is_end_bound_safe_for_groups 🔒

For group-based window frames, determines whether the end bound calculation is safe by considering the group offset and whether the current row is ahead of the most recent row in terms of sorting. It checks if the end bound is within the bounds of the current group based on group end indices.

is_end_bound_safe_for_range 🔒

For row-based window frames, determines whether the end bound calculation is safe by comparing it against specific values (zero, current row). It uses the is_row_ahead helper function to determine if the current row is ahead of the most recent row based on the ORDER BY column and sorting options.

is_end_bound_safe_for_rows 🔒

For row-based window frames, determines whether the end bound calculation is safe, which is trivially the case for Preceding and CurrentRow bounds. For ‘Following’ bounds, it compares the bound value to zero to ensure that it doesn’t extend beyond the current row.

is_row_ahead 🔒

This utility function checks whether current_cols is ahead of the old_cols in terms of sort_options.

Type Aliases

PartitionBatches

The IndexMap (i.e. an ordered HashMap) where record batches are separated for each partition.

PartitionKey

Key for IndexMap for each unique partition

PartitionWindowAggStates