Enum datafusion::logical_expr::window_state::WindowFrameContext

pub enum WindowFrameContext {
    Rows(Arc<WindowFrame, Global>),
    Range {
        window_frame: Arc<WindowFrame, Global>,
        state: WindowFrameStateRange,
    },
    Groups {
        window_frame: Arc<WindowFrame, Global>,
        state: WindowFrameStateGroups,
    },
}

This object stores the window frame state for use in incremental calculations.

Variants

Rows(Arc<WindowFrame, Global>)

ROWS frames are inherently stateless.

Range

Fields

window_frame: Arc<WindowFrame, Global>

state: WindowFrameStateRange

RANGE frames are stateful, they store indices specifying where the previous search left off. This amortizes the overall cost to O(n) where n denotes the row count.

Groups

Fields

window_frame: Arc<WindowFrame, Global>

state: WindowFrameStateGroups

GROUPS frames are stateful, they store group boundaries and indices specifying where the previous search left off. This amortizes the overall cost to O(n) where n denotes the row count.

Implementations

impl WindowFrameContext

pub fn new( window_frame: Arc<WindowFrame, Global>, sort_options: Vec<SortOptions, Global> ) -> WindowFrameContext

Create a new state object for the given window frame.

pub fn calculate_range( &mut self, range_columns: &[Arc<dyn Array, Global>], last_range: &Range<usize>, length: usize, idx: usize ) -> Result<Range<usize>, DataFusionError>

This function calculates beginning/ending indices for the frame of the current row.

Trait Implementations

impl Debug for WindowFrameContext

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

Formats the value using the given formatter.