window_max
Knowledge Checkpoint
Readings that will help you understand this documentation better:
Definition
A window aggregation function that returns the max of rows in a range relative to the current row.
Syntax
window_max(agg_expr)
window_max(agg_expr, order: order_expr, ...)
window_max(agg_expr, range, order: order_expr, ...)
window_max(agg_expr, range, order: order_expr, ..., reset: partition_expr, ...)
window_max(agg_expr, range, order: order_expr, ..., partition: partition_expr, ...)
Examples
window_max(count(users.id))
window_max(count(users.id), order: count(users.id) | desc())
window_max(count(users.id), -2..2, order: users.created_at | month())
window_max(count(users.id), order: users.created_at | month(), reset: users.gender)
Input
agg_expr
(required): An aggregation expression that we want to find max of.range
(optional): A range of rows to include in the max. Negative values indicate rows before the current row, and positive values indicate rows after the current row, while 0 indicates the current row. If the beginning or end of the range is not specified, the range will include all rows from the beginning or end of the table. By default, if the range is not specified:- If
order
is specified, the range is..0
(from the first row to the current row). - If
order
is not specified, the range is..
(from the first row to the last row).
- If
order
(required, repeatable): A field that is used for ordering. The order is default to ascending. The order can be set explicitly withasc()
ordesc()
.dangerIf the specified order does not uniquely identify rows, the result of the function can be non-deterministic. For example, if you use
order: users.age
, and there are multiple users with the same age in the same partition, the result can be unexpected.partition
orreset
(repeatable, optional): A field that is used for partitioning the table. If partitions are not specified:- If
order
is specified, the table will be partitioned by all other grouping columns. - If
order
is not specified, the table will be considered as a single partition.
- If
Output
The max of the current row and the rows within the specified range.
Sample Usages
Refer to the sample usages in window_sum.