[][src]Module datafusion::execution::physical_plan

Traits for physical query plan, supporting parallel execution for partitioned relations.

Modules

common

Defines common code used in execution plans

csv

Execution plan for reading CSV files

datasource

ExecutionPlan implementation for DataFusion data sources

expressions

Defines physical expressions that can evaluated at runtime during query execution

hash_aggregate

Defines the execution plan for the hash aggregate operation

merge

Defines the merge plan for executing partitions in parallel and then merging the results into a single partition

projection

Defines the projection execution plan. A projection determines which columns or expressions are returned from a query. The SQL statement SELECT a, b, a+b FROM t1 is an example of a projection on table t1 where the expressions a, b, and a+b are the projection expressions.

selection

Defines the selection execution plan. A selection filters rows based on a predicate

Traits

Accumulator

Aggregate accumulator

AggregateExpr

Agggregate expression that can be evaluated against a RecordBatch

BatchIterator

Iterator over RecordBatch that can be sent between threads

ExecutionPlan

Partition-aware execution plan for a relation

Partition

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

PhysicalExpr

Expression that can be evaluated against a RecordBatch