Module datafusion_physical_expr::window
source · Structs
A window expr that takes the form of a built in window function
State for each unique partition determined according to PARTITION BY column(s)
A window expr that takes the form of an aggregate function
Aggregate Window Expressions that have the form
OVER({ROWS | RANGE| GROUPS} BETWEEN UNBOUNDED PRECEDING AND ...)
e.g cumulative window frames uses PlainAggregateWindowExpr. Where as Aggregate Window Expressions
that have the form OVER({ROWS | RANGE| GROUPS} BETWEEN M {PRECEDING| FOLLOWING} AND ...)
e.g sliding window frames uses SlidingAggregateWindowExpr.A window expr that takes the form of an aggregate function
Aggregate Window Expressions that have the form
OVER({ROWS | RANGE| GROUPS} BETWEEN UNBOUNDED PRECEDING AND ...)
e.g cumulative window frames uses PlainAggregateWindowExpr. Where as Aggregate Window Expressions
that have the form OVER({ROWS | RANGE| GROUPS} BETWEEN M {PRECEDING| FOLLOWING} AND ...)
e.g sliding window frames uses SlidingAggregateWindowExpr.Traits
A window expression that is a built-in window function.
A window expression that:
Type Definitions
The IndexMap (i.e. an ordered HashMap) where record batches are separated for each partition.
key for IndexMap for each unique partition
For instance, if window frame is OVER(PARTITION BY a,b)
PartitionKey would consist of unique [a,b] pairs