Trait datafusion::execution::physical_plan::ExecutionPlan

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

Partition-aware execution plan for a relation

Required methods

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

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) -> Arc<Schema>

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) -> Arc<Schema>

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

impl ExecutionPlan for HashAggregateExec

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

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

impl ExecutionPlan for MergeExec

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

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

impl ExecutionPlan for ProjectionExec

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

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) -> Arc<Schema>

Get the schema for this execution plan

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

Get the partitions for this execution plan

Loading content...