Module bounded_window_agg_exec 

Stream and channel implementations for window function expressions. The executor given here uses bounded memory (does not maintain all the input data seen so far), which makes it appropriate when processing infinite inputs.

Structs

BoundedWindowAggExec

Window execution plan

BoundedWindowAggStream

Stream for the bounded window aggregation plan.

LinearSearch

This object encapsulates the algorithm state for a simple linear scan algorithm for computing partitions.

SortedSearch

This object encapsulates the algorithm state for sorted searching when computing partitions.

Traits

PartitionSearcher 🔒

Trait that specifies how we search for (or calculate) partitions. It has two implementations: SortedSearch and LinearSearch.

Functions

argmin 🔒

evaluate_partition_by_column_values 🔒

Calculates partition by expression results for each window expression on record_batch.

get_aggregate_result_out_column 🔒

Calculates the section we can show results for expression

get_last_row_batch 🔒

Constructs a batch from the last row of batch in the argument.