Trait datafusion::execution::physical_plan::ExecutionPlan

pub trait ExecutionPlan {
    fn schema(&self) -> SchemaRef;
    fn partitions(&self) -> Result<Vec<Arc<dyn Partition>>>;
}

Partition-aware execution plan for a relation

Required methods

fn schema(&self) -> SchemaRef

Get the schema for this execution plan

fn partitions(&self) -> Result<Vec<Arc<dyn Partition>>>

Get the partitions for this execution plan. Each partition can be executed in parallel.

Loading content...

Implementors

impl ExecutionPlan for CsvExec

fn schema(&self) -> SchemaRef

Get the schema for this execution plan

fn partitions(&self) -> Result<Vec<Arc<dyn Partition>>>

Get the partitions for this execution plan. Each partition can be executed in parallel.

impl ExecutionPlan for DatasourceExec

fn schema(&self) -> SchemaRef

fn partitions(&self) -> Result<Vec<Arc<dyn Partition>>>

impl ExecutionPlan for HashAggregateExec

fn schema(&self) -> SchemaRef

fn partitions(&self) -> Result<Vec<Arc<dyn Partition>>>

impl ExecutionPlan for LimitExec

fn schema(&self) -> SchemaRef

fn partitions(&self) -> Result<Vec<Arc<dyn Partition>>>

impl ExecutionPlan for MemoryExec

fn schema(&self) -> SchemaRef

Get the schema for this execution plan

fn partitions(&self) -> Result<Vec<Arc<dyn Partition>>>

Get the partitions for this execution plan. Each partition can be executed in parallel.

impl ExecutionPlan for MergeExec

fn schema(&self) -> SchemaRef

fn partitions(&self) -> Result<Vec<Arc<dyn Partition>>>

impl ExecutionPlan for ParquetExec

fn schema(&self) -> SchemaRef

fn partitions(&self) -> Result<Vec<Arc<dyn Partition>>>

impl ExecutionPlan for ProjectionExec

fn schema(&self) -> SchemaRef

Get the schema for this execution plan

fn partitions(&self) -> Result<Vec<Arc<dyn Partition>>>

Get the partitions for this execution plan

impl ExecutionPlan for SelectionExec

fn schema(&self) -> SchemaRef

Get the schema for this execution plan

fn partitions(&self) -> Result<Vec<Arc<dyn Partition>>>

Get the partitions for this execution plan

impl ExecutionPlan for SortExec

fn schema(&self) -> SchemaRef

fn partitions(&self) -> Result<Vec<Arc<dyn Partition>>>

Loading content...