Struct RecordBatches

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

Fields

schema: Arc<Schema>

batches: Vec<RecordBatch>

Implementations

impl RecordBatches

pub fn try_from_columns<I>( schema: Arc<Schema>, columns: I, ) -> Result<RecordBatches, Error>

where I: IntoIterator<Item = Arc<dyn Vector>>,

pub async fn try_collect( stream: Pin<Box<dyn RecordBatchStream<Item = Result<RecordBatch, Error>> + Send>>, ) -> Result<RecordBatches, Error>

pub fn empty() -> RecordBatches

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

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

pub fn try_new( schema: Arc<Schema>, batches: Vec<RecordBatch>, ) -> Result<RecordBatches, Error>

pub fn schema(&self) -> Arc<Schema>

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

pub fn as_stream( &self, ) -> Pin<Box<dyn RecordBatchStream<Item = Result<RecordBatch, Error>> + Send>>

Trait Implementations

impl Debug for RecordBatches

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

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) -> <RecordBatches as IntoIterator>::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