Struct RecordBatch 

pub struct RecordBatch {
    pub num_rows: usize,
    pub schema: Vec<ColumnSchema>,
    pub float_columns: Vec<Float64Column>,
    pub int_columns: Vec<Int32Column>,
    pub uint8_columns: Vec<Uint8Column>,
}

A record batch: a named collection of typed columns.

This is the primary unit for zero-copy data transfer. Analogous to Arrow RecordBatch.

Fields

num_rows: usize

Number of rows in the batch.

schema: Vec<ColumnSchema>

Schema: column names and types.

float_columns: Vec<Float64Column>

Float64 columns.

int_columns: Vec<Int32Column>

Int32 columns.

uint8_columns: Vec<Uint8Column>

Uint8 columns.

Implementations

impl RecordBatch

pub fn new() -> Self

Create an empty batch.

pub fn add_float64(&mut self, name: &str, values: Vec<f64>, shape: Vec<usize>)

Add a Float64 column.

pub fn add_int32(&mut self, name: &str, values: Vec<i32>, shape: Vec<usize>)

Add an Int32 column.

pub fn add_uint8(&mut self, name: &str, values: Vec<u8>, shape: Vec<usize>)

Add a Uint8 column.

pub fn byte_size(&self) -> usize

Total byte size of all buffers (for transfer cost estimation).

pub fn num_columns(&self) -> usize

Number of columns.

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 Default for RecordBatch

fn default() -> RecordBatch

Returns the “default value” for a type.

impl<'de> Deserialize<'de> for RecordBatch

fn deserialize<__D>(__deserializer: __D) -> Result<Self, __D::Error>

where __D: Deserializer<'de>,

Deserialize this value from the given Serde deserializer.

impl Serialize for RecordBatch

fn serialize<__S>(&self, __serializer: __S) -> Result<__S::Ok, __S::Error>

where __S: Serializer,

Serialize this value into the given Serde serializer.