Trait RecordBatchStream 

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

Trait for types that stream RecordBatch

See SendableRecordBatchStream for more details.

Required Methods

fn schema(&self) -> SchemaRef

Returns the schema of this RecordBatchStream.

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

Implementors