This is an automated email from the ASF dual-hosted git repository.
milenkovicm pushed a commit to branch main
in repository https://gitbox.apache.org/repos/asf/datafusion-ballista.git
The following commit(s) were added to refs/heads/main by this push:
new e5dc7245 doc: Fix plan translation example to use correct aggregation
and column (#1362)
e5dc7245 is described below
commit e5dc724573864a2558c78f9fdda67942c75786ff
Author: Matt Cuento <[email protected]>
AuthorDate: Sun Jan 4 05:23:17 2026 -0800
doc: Fix plan translation example to use correct aggregation and column
(#1362)
Fix more references
---
docs/source/contributors-guide/architecture.md | 10 +++++-----
1 file changed, 5 insertions(+), 5 deletions(-)
diff --git a/docs/source/contributors-guide/architecture.md
b/docs/source/contributors-guide/architecture.md
index 5f0333f9..b0e00730 100644
--- a/docs/source/contributors-guide/architecture.md
+++ b/docs/source/contributors-guide/architecture.md
@@ -132,7 +132,7 @@ The physical (non-distributed) plan for this query would
look something like thi
```
Projection: #customer.id, #total_amount
- HashAggregate: groupBy=[customer.id], aggr=[MAX(max_fare) AS total_amount]
+ HashAggregate: groupBy=[customer.id], aggr=[SUM(order.amount) AS
total_amount]
Join: condition=[customer.id = order.customer_id]
Scan: customer
Scan: order
@@ -157,7 +157,7 @@ remains partitioned by customer id.
```
Query Stage #3: repartition=[]
- HashAggregate: groupBy=[customer.id], aggr=[MAX(max_fare) AS total_amount]
+ HashAggregate: groupBy=[customer.id], aggr=[SUM(order.amount) AS
total_amount]
Join: condition=[customer.id = order.customer_id]
Query Stage #1
Query Stage #2
@@ -169,7 +169,7 @@ stage.
```
Query Stage #4:
Projection: #customer.id, #total_amount
- HashAggregate: groupBy=[customer.id], aggr=[MAX(max_fare) AS total_amount]
+ HashAggregate: groupBy=[customer.id], aggr=[SUM(order.amount) AS
total_amount]
QueryStage #3
```
@@ -179,9 +179,9 @@ repartitioned or exchanged between pipelined operations.
```
Query Stage #4:
Projection: #customer.id, #total_amount
- HashAggregate: groupBy=[customer.id], aggr=[MAX(max_fare) AS total_amount]
+ HashAggregate: groupBy=[customer.id], aggr=[SUM(order.amount) AS
total_amount]
Query Stage #3: repartition=[]
- HashAggregate: groupBy=[customer.id], aggr=[MAX(max_fare) AS
total_amount]
+ HashAggregate: groupBy=[customer.id], aggr=[SUM(order.amount) AS
total_amount]
Join: condition=[customer.id = order.customer_id]
Query Stage #1: repartition=[customer.id]
Scan: customer
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
