Trait datafusion::physical_plan::RecordBatchStream
source · pub trait RecordBatchStream: Stream<Item = Result<RecordBatch>> {
// Required method
fn schema(&self) -> SchemaRef;
}
Expand description
Trait for types that stream arrow::record_batch::RecordBatch