Struct RecordBatch 

pub struct RecordBatch { /* private fields */ }

A decoded block with one logical array per schema column.

Implementations

impl RecordBatch

pub fn try_new( schema: Arc<Schema>, columns: Vec<Array>, row_count: usize, ) -> Result<Self>

Build a batch from arrays that already have one position per row.

The row count is given rather than taken from the first array, so a batch keeps its shape independently of how many columns it has, and every array is checked against it.

pub fn schema(&self) -> &Schema

The schema shared by this batch.

pub fn columns(&self) -> &[Array]

The decoded arrays in schema order.

pub fn row_count(&self) -> usize

The number of logical rows in the block.

pub fn column_by_name(&self, name: &str) -> Option<&Array>

Find a decoded array by its schema column name.

pub fn column(&self, index: usize) -> Option<&Array>

Get a decoded array by schema position.

Trait Implementations

impl Clone for RecordBatch

fn clone(&self) -> RecordBatch

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for RecordBatch

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

Formats the value using the given formatter.

impl PartialEq for RecordBatch

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

Equality operator ==.

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

Inequality operator !=.

impl StructuralPartialEq for RecordBatch