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.

Dyn Compatibility

This trait is dyn compatible.

In older versions of Rust, dyn compatibility was called "object safety".

Implementors

impl<S> RecordBatchStream for RecordBatchStreamAdapter<S>

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