Module plan_fragmenter 

Structs

BatchPlanFragmenter

BatchPlanFragmenter splits a query plan into fragments.

ExecutionPlanNode

Generated by BatchPlanFragmenter and used in query execution graph.

FileScanInfo

IcebergSpecificInfo

Query

The fragmented query generated by BatchPlanFragmenter.

QueryId

QueryStage

Fragment part of Query.

QueryStageBuilder 🔒

SourceFetchInfo

StageGraph

Maintains how each stage are connected.

StageGraphBuilder 🔒

StageId

TablePartitionInfo

TableScanInfo

Enums

PartitionInfo

SourceFetchParameters

SourceScanInfo

StageCompleteInfo 🔒

Constants

ROOT_TASK_ID

ROOT_TASK_OUTPUT_ID

Functions

derive_partitions 🔒

Try to derive the partition to read from the scan range. It can be derived if the value of the distribution key is already known.

Type Aliases

TaskId