Trait datafusion::execution::physical_plan::Partition

pub trait Partition: Send + Sync {
    fn execute(&self) -> Result<Arc<Mutex<dyn RecordBatchReader + Send + Sync>>>;
}

Represents a partition of an execution plan that can be executed on a thread

Required methods

fn execute(&self) -> Result<Arc<Mutex<dyn RecordBatchReader + Send + Sync>>>

Execute this partition and return an iterator over RecordBatch

Loading content...

Implementors

impl Partition for DatasourcePartition

fn execute(&self) -> Result<Arc<Mutex<dyn RecordBatchReader + Send + Sync>>>

Loading content...