Struct BatchLoadState 

pub struct BatchLoadState { /* private fields */ }

Batch/chunk state machine shared by executemany ingestion and direct path load. Port of BatchLoadManager/DataFrameBatchLoadManager (impl/base/batch_load_manager.pyx).

The data source is modelled as a list of chunks (an Arrow chunked array has one entry per chunk; a plain list of rows is a single chunk). Batches never span chunk boundaries; message_offset is the row offset within the current chunk that must accompany the execute/load message.

Implementations

impl BatchLoadState

pub fn new(chunk_lengths: Vec<u64>, batch_size: u32) -> Result<Self>

pub fn for_rows(total_rows: u64, batch_size: u32) -> Result<Self>

Creates the state machine for a single-chunk source of total_rows rows (a plain list of rows).

pub fn num_rows(&self) -> u32

Number of rows in the current batch; zero means the load is complete.

pub fn offset(&self) -> u64

Row offset of the current batch within the current chunk.

pub fn message_offset(&self) -> u64

Offset to send with the execute/load message (row offset within the current chunk at the time the batch was formed).

pub fn chunk_index(&self) -> usize

Index of the chunk the current batch draws from.

pub fn is_done(&self) -> bool

pub fn next_batch(&mut self)

Advances to the next batch (mirrors BatchLoadManager.next_batch).

Trait Implementations

impl Clone for BatchLoadState

fn clone(&self) -> BatchLoadState

Returns a duplicate of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.

impl Debug for BatchLoadState

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

Formats the value using the given formatter.

impl Eq for BatchLoadState

impl PartialEq for BatchLoadState

fn eq(&self, other: &BatchLoadState) -> bool

Tests for self and other values to be equal, and is used by ==.

fn ne(&self, other: &Rhs) -> bool

Tests for !=. The default implementation is almost always sufficient, and should not be overridden without very good reason.

impl StructuralPartialEq for BatchLoadState