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.

Loading content...

Implementors

impl RecordBatchStream for SizedRecordBatchStream

fn schema(&self) -> SchemaRef

Loading content...