Struct RecordBatches

pub struct RecordBatches {
    pub(crate) schema: SchemaRef,
    pub(crate) batches: Vec<RecordBatch>,
}

Fields

schema: SchemaRef

batches: Vec<RecordBatch>

Implementations

impl RecordBatches

pub fn try_from_columns<I: IntoIterator<Item = VectorRef>>( schema: SchemaRef, columns: I, ) -> Result<Self>

pub async fn try_collect(stream: SendableRecordBatchStream) -> Result<Self>

pub fn empty() -> Self

pub fn iter(&self) -> impl Iterator<Item = &RecordBatch>

pub fn pretty_print(&self) -> Result<String>

pub fn try_new(schema: SchemaRef, batches: Vec<RecordBatch>) -> Result<Self>

pub fn schema(&self) -> SchemaRef

pub fn take(self) -> Vec<RecordBatch>

pub fn as_stream(&self) -> SendableRecordBatchStream

pub fn into_df_stream(self) -> DfSendableRecordBatchStream

Trait Implementations

impl Debug for RecordBatches

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

Formats the value using the given formatter.

impl IntoIterator for RecordBatches

type Item = RecordBatch

The type of the elements being iterated over.

type IntoIter = IntoIter<<RecordBatches as IntoIterator>::Item>

Which kind of iterator are we turning this into?

fn into_iter(self) -> Self::IntoIter

Creates an iterator from a value.

impl PartialEq for RecordBatches

fn eq(&self, other: &RecordBatches) -> 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 StructuralPartialEq for RecordBatches