Struct Batch

pub struct Batch {
    batch: Vec<VectorRef>,
    row_count: usize,
    diffs: Option<VectorRef>,
}

A batch of vectors with the same length but without schema, only useful in dataflow

somewhere cheap to clone since it just contains a list of VectorRef(which is a Arc).

Fields

batch: Vec<VectorRef>

row_count: usize

diffs: Option<VectorRef>

describe if corresponding rows in batch is insert or delete, None means all rows are insert

Implementations

impl Batch

pub fn try_from_rows_with_types( rows: Vec<Row>, batch_datatypes: &[ConcreteDataType], ) -> Result<Self, EvalError>

Get batch from rows, will try best to determine data type

pub fn empty() -> Self

pub fn try_new( batch: Vec<VectorRef>, row_count: usize, ) -> Result<Self, EvalError>

pub fn new_unchecked(batch: Vec<VectorRef>, row_count: usize) -> Self

pub fn batch(&self) -> &[VectorRef]

pub fn batch_mut(&mut self) -> &mut Vec<VectorRef>

pub fn row_count(&self) -> usize

pub fn set_row_count(&mut self, row_count: usize)

pub fn column_count(&self) -> usize

pub fn get_row(&self, idx: usize) -> Result<Vec<Value>, EvalError>

pub fn slice(&self, offset: usize, length: usize) -> Result<Batch, EvalError>

Slices the Batch, returning a new Batch.

pub fn append_batch(&mut self, other: Batch) -> Result<(), EvalError>

append another batch to self

NOTE: This is expensive since it will create new vectors for each column

pub fn filter(&self, predicate: &BooleanVector) -> Result<Self, EvalError>

filter the batch with given predicate

Trait Implementations

impl Clone for Batch

fn clone(&self) -> Batch

Returns a copy of the value.

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

Performs copy-assignment from source.

impl Debug for Batch

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

Formats the value using the given formatter.

impl Default for Batch

fn default() -> Self

Returns the “default value” for a type.

impl From<RecordBatch> for Batch

fn from(value: RecordBatch) -> Self

Converts to this type from the input type.

impl PartialEq for Batch

fn eq(&self, other: &Self) -> 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 Eq for Batch