Module window 

Modules

aggregate 🔒

Physical exec for aggregate window function expressions.

sliding_aggregate 🔒

Physical exec for aggregate window function expressions.

standard 🔒

Physical exec for standard window function expressions.

standard_window_function_expr 🔒

window_expr 🔒

Structs

PlainAggregateWindowExpr

A window expr that takes the form of an aggregate function.

SlidingAggregateWindowExpr

A window expr that takes the form of an aggregate function that can be incrementally computed over sliding windows.

StandardWindowExpr

A window expr that takes the form of a StandardWindowFunctionExpr.

WindowState

Traits

StandardWindowFunctionExpr

Evaluates a window function by instantiating a [PartitionEvaluator] for calculating the function’s output in that partition.

WindowExpr

Common trait for window function implementations

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