Module execution_engine

kapot_executor

Module execution_engine 

Source

Structs§

DefaultExecutionEngine
DefaultQueryStageExec

Traits§

ExecutionEngine
Execution engine extension point
QueryStageExecutor
QueryStageExecutor executes a section of a query plan that has consistent partitioning and can be executed as one unit with each partition being executed in parallel. The output of each partition is re-partitioned and streamed to disk in Arrow IPC format. Future stages of the query will use the ShuffleReaderExec to read these results.