Struct datafusion_expr::window_state::PartitionBatchState
source · pub struct PartitionBatchState {
pub record_batch: RecordBatch,
pub is_end: bool,
pub n_out_row: usize,
}
Expand description
State for each unique partition determined according to PARTITION BY column(s)
Fields§
§record_batch: RecordBatch
The record_batch belonging to current partition
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
Trait Implementations§
Auto Trait Implementations§
impl !RefUnwindSafe for PartitionBatchState
impl Send for PartitionBatchState
impl Sync for PartitionBatchState
impl Unpin for PartitionBatchState
impl !UnwindSafe for PartitionBatchState
Blanket Implementations§
source§impl<T> BorrowMut<T> for Twhere
T: ?Sized,
impl<T> BorrowMut<T> for Twhere T: ?Sized,
source§fn borrow_mut(&mut self) -> &mut T
fn borrow_mut(&mut self) -> &mut T
Mutably borrows from an owned value. Read more