Skip to main content

RecordBatchStream

arrow_array::nonblocking

Trait RecordBatchStream 

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

Trait for an asynchronous stream of RecordBatches.

Required Methods§

Source

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§