Struct Batch 

pub struct Batch {
    pub schema: RowSchema,
    pub rows: Vec<PhysicalRow>,
}

A schema and bounded vector of physical rows flowing between operators.

Fields

schema: RowSchema

rows: Vec<PhysicalRow>

Implementations

impl Batch

pub fn new(schema: RowSchema, rows: Vec<ResultRow>) -> Self

Compatibility constructor for named rows entering the physical engine. The resulting batch is positional immediately; maps do not flow to the next operator.

pub fn from_physical_rows(schema: RowSchema, rows: Vec<PhysicalRow>) -> Self

pub fn empty(schema: RowSchema) -> Self

pub fn len(&self) -> usize

pub fn is_empty(&self) -> bool

pub fn into_result_rows(self) -> Vec<ResultRow>

pub fn into_owned_rows(self) -> Vec<OwnedPhysicalRow>

Consume a batch without materializing named maps.

pub fn chunked(schema: RowSchema, rows: Vec<ResultRow>) -> Vec<Batch>

Split named rows into batches of at most DEFAULT_BATCH_SIZE.

Trait Implementations

impl Clone for Batch

fn clone(&self) -> Batch

Returns a duplicate 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 PartialEq for Batch

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

Equality operator ==.

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

Inequality operator !=.

impl StructuralPartialEq for Batch