Skip to content

Commit ac6ac3f

Browse files
committed
refine global aggregation, take 2
1 parent bd1f99d commit ac6ac3f

File tree

2 files changed

+682
-0
lines changed

2 files changed

+682
-0
lines changed

docs/global-aggregation.md

Lines changed: 4 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -94,6 +94,10 @@ SETTINGS
9494
- Data shuffling is enabled (SHUFFLE BY location) for better **parallelism and memory efficiency**.
9595
- See [Data Shuffle](/shuffle-data) for more details.
9696

97+
The internal query plan for this hybrid global aggregation looks like:
98+
99+
![HybridAggregationPipeline](/img/hybrid-aggregation-pipeline.svg)
100+
97101
## Emit Policies
98102

99103
Global aggregation supports different `emit policies` to control when you like to get the intermidiate results pushing out.

0 commit comments

Comments
 (0)