Expand description
Physical Operators Module Physical Operators Module
Re-exports§
pub use shuffle::GridShuffleWriterOperator;
Modules§
Structs§
- Filter
Operator - 필터 연산자 (WHERE 조건) — Arrow compute kernel로 predicate 평가
- Grid
Exchange Operator - 분산 쿼리 스트리밍 파이프라인의 물리 오퍼레이터 (수신 담당) 코디네이터 노드에서 상위 연산자(Aggregate 등)에 연결되어 Bounded Channel로부터 동기적으로(blocking) 바이너리 배치를 가져옵니다.
- Hash
Aggregate Operator - Hash Aggregate 연산자 (GROUP BY) — AHashMap 기반 집계
- Hash
Join Operator - Limit
Operator - Limit 연산자 (LIMIT/OFFSET)
- Projection
Operator - Projection 연산자 (SELECT 컬럼 선택/계산)
- Sort
Operator - Sort 연산자 (ORDER BY) — Arrow sort_to_indices 활용
- Table
Scan Operator - 테이블 스캔 연산자 — 5-Tier 하이브리드 스트리밍 지원 (Phase 6)
Traits§
- Physical
Operator - 물리 연산자 트레이트 — Volcano 실행 모델 (Pull 기반)