Trait RecordBatchStream 

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

Available on crate feature async only.

Trait for an asynchronous stream of RecordBatches.

Required Methods

fn schema(&self) -> &SchemaRef

Return the schema of this RecordBatchStream.

Implementation of this trait should guarantee that all RecordBatch’s returned by this reader should have the same schema as returned from this method.

Implementors