Trait lance_core::io::RecordBatchStream

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

RecordBatch Stream trait.

Required Methods§

source

fn schema(&self) -> SchemaRef

Returns the schema of the stream.

Implementors§

source§

impl<S> RecordBatchStream for RecordBatchStreamAdapter<S>
where S: Stream<Item = Result<RecordBatch>> + Send + 'static,