Trait datafusion_execution::RecordBatchStream

source · 
pub trait RecordBatchStream: Stream<Item = Result<RecordBatch>> {
    // Required method
    fn schema(&self) -> SchemaRef;
}
Expand description

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

Required Methods§

source

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§