Struct deltalake::datafusion::logical_expr::window_state::PartitionBatchState

pub struct PartitionBatchState {
    pub record_batch: RecordBatch,
    pub most_recent_row: Option<RecordBatch>,
    pub is_end: bool,
    pub n_out_row: usize,
}

State for each unique partition determined according to PARTITION BY column(s)

Fields

record_batch: RecordBatch

The record batch belonging to current partition

most_recent_row: Option<RecordBatch>

The record batch that contains the most recent row at the input. Please note that this batch doesn’t necessarily have the same partitioning with record_batch. Keeping track of this batch enables us to prune record_batch when cardinality of the partition is sparse.

is_end: bool

Flag indicating whether we have received all data for this partition

n_out_row: usize

Number of rows emitted for each partition

Implementations

impl PartitionBatchState

pub fn new(schema: Arc<Schema>) -> PartitionBatchState

pub fn extend(&mut self, batch: &RecordBatch) -> Result<(), DataFusionError>

pub fn set_most_recent_row(&mut self, batch: RecordBatch)

Trait Implementations

impl Debug for PartitionBatchState

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

Formats the value using the given formatter.