Trait datafusion::physical_plan::RecordBatchStream

pub trait RecordBatchStream: Stream<Item = ArrowResult<RecordBatch>> {
    fn schema(&self) -> SchemaRef;
}

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

Required Methods

fn schema(&self) -> SchemaRef

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 SizedRecordBatchStream

impl RecordBatchStream for MemoryStream

impl RecordBatchStream for RecordBatchReceiverStream

impl RecordBatchStream for EmptyRecordBatchStream

impl<S> RecordBatchStream for RecordBatchStreamAdapter<S> where
    S: Stream<Item = ArrowResult<RecordBatch>>,