Trait RecordBatchStream 

pub trait RecordBatchStream: Stream<Item = Result<RecordBatch, DataFusionError>> {
    // Required method
    fn schema(&self) -> Arc<Schema> ;
}

The record-batch stream trait, re-exported for the same reason as MemoryPool.

A fragment’s real output schema is the one its stream declares, not the one its DataFrame does — physical planning re-types expressions, and TPC-H q17 shipped batches of Decimal128(30, 15) under a logical schema that said Decimal128(15, 2). Reading it needs this trait in scope, and the executor should not take a DataFusion dependency to do that. Trait for types that stream RecordBatch

See SendableRecordBatchStream for more details.

Required Methods

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

Returns the schema of this RecordBatchStream.

Implementation of this trait should guarantee that all RecordBatch’s returned by this stream should have the same schema as returned from this method.

Trait Implementations

impl From<StreamType> for Pin<Box<dyn RecordBatchStream<Item = Result<RecordBatch, DataFusionError>> + Send>>

fn from( stream: StreamType, ) -> Pin<Box<dyn RecordBatchStream<Item = Result<RecordBatch, DataFusionError>> + Send>>

Converts to this type from the input type.

Dyn Compatibility

This trait is dyn compatible.

In older versions of Rust, dyn compatibility was called "object safety".

Implementations on Foreign Types

impl RecordBatchStream for BatchSplitStream

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

impl RecordBatchStream for BlockingStream

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

impl RecordBatchStream for EmptyRecordBatchStream

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

impl RecordBatchStream for FileStream

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

impl RecordBatchStream for LazyMemoryStream

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

impl RecordBatchStream for LimitStream

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

Get the schema

impl RecordBatchStream for MemoryStream

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

Get the schema

impl RecordBatchStream for SpillPoolReader

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

impl RecordBatchStream for TestStream

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

Get the schema

impl<S> RecordBatchStream for RecordBatchStreamAdapter<S>

where S: Stream<Item = Result<RecordBatch, DataFusionError>>,

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

impl<T> RecordBatchStream for CooperativeStream<T>

where T: RecordBatchStream + Unpin,

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

Implementors