Struct WindowAggState 

pub struct WindowAggState {
    pub window_frame_range: Range<usize>,
    pub window_frame_ctx: Option<WindowFrameContext>,
    pub last_calculated_index: usize,
    pub offset_pruned_rows: usize,
    pub out_col: ArrayRef,
    pub n_row_result_missing: usize,
    pub is_end: bool,
}

Holds the state of evaluating a window function

Fields

window_frame_range: Range<usize>

The range that we calculate the window function

window_frame_ctx: Option<WindowFrameContext>

last_calculated_index: usize

The index of the last row that its result is calculated inside the partition record batch buffer.

offset_pruned_rows: usize

The offset of the deleted row number

out_col: ArrayRef

Stores the results calculated by window frame

n_row_result_missing: usize

Keeps track of how many rows should be generated to be in sync with input record_batch.

is_end: bool

Flag indicating whether we have received all data for this partition

Implementations

impl WindowAggState

pub fn prune_state(&mut self, n_prune: usize)

pub fn update( &mut self, out_col: &ArrayRef, partition_batch_state: &PartitionBatchState, ) -> Result<()>

pub fn is_up_to_date_with( &self, partition_batch_state: &PartitionBatchState, ) -> bool

Returns true when this state is fully up to date with the partition’s buffered batch, meaning another evaluation pass over the partition could not produce any new results or change any state:

• last_calculated_index has reached the end of the partition’s buffered batch, so every row of this partition that has arrived so far already has a result.
• When a partition ends, a final evaluation pass is needed to bring derived state up to date.

pub fn new(out_type: &DataType) -> Result<Self>

Trait Implementations

impl Clone for WindowAggState

fn clone(&self) -> WindowAggState

Returns a duplicate of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.

impl Debug for WindowAggState

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.