Trait datafusion::physical_plan::execution_plan::RecordBatchStream

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

Trait for types that stream arrow::record_batch::RecordBatch

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.

Implementors

impl RecordBatchStream for LimitStream

impl RecordBatchStream for MemoryStream

impl RecordBatchStream for EmptyRecordBatchStream

impl<F: FileOpener> RecordBatchStream for FileStream<F>

impl<S> RecordBatchStream for RecordBatchStreamAdapter<S>

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