datafusion_physical_plan::execution_plan

Trait RecordBatchStream

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

Trait for types that stream RecordBatch

See SendableRecordBatchStream for more details.

Required Methods§

Source

fn schema(&self) -> Arc<Schema>

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§