Trait RecordBatchStream

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

RecordBatch Stream trait.

Required Methods

fn schema(&self) -> SchemaRef

Returns the schema of the stream.

Implementors

impl<S> RecordBatchStream for RecordBatchStreamAdapter<S>

where S: Stream<Item = Result<RecordBatch>> + Send + 'static,