Trait datafusion::physical_plan::streaming::PartitionStream
source · pub trait PartitionStream: Send + Sync {
// Required methods
fn schema(&self) -> &SchemaRef;
fn execute(&self, ctx: Arc<TaskContext>) -> SendableRecordBatchStream;
}
Expand description
A partition that can be converted into a SendableRecordBatchStream
Required Methods§
sourcefn execute(&self, ctx: Arc<TaskContext>) -> SendableRecordBatchStream
fn execute(&self, ctx: Arc<TaskContext>) -> SendableRecordBatchStream
Returns a stream yielding this partitions values