Skip to main content

Module fragment_splitter

Module fragment_splitter 

Source
Expand description

Fragment Splitter — 분산 쿼리 플랜 분할기

PhysicalPlan 트리를 분석하여 분산 실행 경계(Partial/Final Aggregate)를 찾고, 코디네이터가 실행할 서브트리와 워커가 실행할 서브트리로 분리합니다.

분기 규칙:

  • PhysicalPlan::HashAggregate { mode: Final } 노드부터 위가 Coordinator Fragment
  • PhysicalPlan::HashAggregate { mode: Partial } 노드부터 아래가 Worker Fragment
  • Coordinator Fragment의 입력은 GridExchangeOperator로 대체됨 (채널 연결)

§지원하지 않는 케이스 (Phase 3 범위 외)

  • 분산 Join (Shuffle Exchange) — Phase 4에서 구현

Structs§

FragmentDAG
분할 결과 — 코디네이터 플랜과 스테이지 배열의 쌍 (Fragment DAG)
FragmentSplitter
FragmentStage