pub struct PartitionBatchState {
pub record_batch: RecordBatch,
pub is_end: bool,
}
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
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