Enum datafusion_python::datafusion_expr::window_state::WindowFrameContext

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

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

Variants

Rows(Arc<WindowFrame>)

ROWS frames are inherently stateless.

Range

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.

Fields

window_frame: Arc<WindowFrame>

state: WindowFrameStateRange

Groups

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.

Fields

window_frame: Arc<WindowFrame>

state: WindowFrameStateGroups

Implementations

impl WindowFrameContext

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

Create a new state object for the given window frame.

pub fn calculate_range( &mut self, range_columns: &[Arc<dyn Array>], 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.