Module plan_fragmenter

Source

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 🔒
TablePartitionInfo
TableScanInfo

Enums§

PartitionInfo
SourceFetchParameters
SourceScanInfo

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§

QueryStageRef
StageId
TaskId