Struct datafusion_python::datafusion_expr::window_state::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: Arc<dyn Array>,
    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: Arc<dyn Array>

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: &Arc<dyn Array>, partition_batch_state: &PartitionBatchState, ) -> Result<(), DataFusionError>

pub fn new(out_type: &DataType) -> Result<WindowAggState, DataFusionError>

Trait Implementations

impl Debug for WindowAggState

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

Formats the value using the given formatter.