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

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

Required Methods§

source

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§