Struct ArrowBatch 

pub struct ArrowBatch { /* private fields */ }

Implementations

impl ArrowBatch

pub fn try_new(batch: RecordBatch) -> Result<ArrowBatch, Error>

pub fn try_map<U, E>( self, additional_peak: usize, map: impl FnOnce(RecordBatch) -> Result<U, E>, ) -> Result<ReadBatch<U>, E>

where E: From<Error>,

Projects an admitted batch while preserving its original shared claim.

additional_peak bounds new output allocations and conversion scratch. Private output-owner storage is admitted separately, before the callback. Immutable Arrow buffer clones and slices may share the original claim. The callback must transfer payloads only into its successful value; errors and external captures must not retain them. Nested owners retain their guards. Unretained batches from try_new or from_ipc refuse without conversion.

pub fn as_record_batch(&self) -> &RecordBatch

pub fn ipc_bytes(&self) -> &[u8]

pub fn from_ipc(bytes: Vec<u8>) -> Result<ArrowBatch, Error>

pub fn validate_schema(&self, schema: &Schema) -> Result<(), Error>

Trait Implementations

impl Clone for ArrowBatch

fn clone(&self) -> ArrowBatch

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for ArrowBatch

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

Formats the value using the given formatter.

impl MemorySize for ArrowBatch

fn memory_size(&self) -> usize

const INLINE_ONLY: bool = false

True only when every value occupies exactly size_of::<Self>() bytes, with no separately owned allocations or additional accounting charge.