datafusion_execution

Trait RecordBatchStream

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

Trait for types that stream RecordBatch

See SendableRecordBatchStream for more details.

Required Methods§

Source

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§