blob: b98f872c4b2ce6dfa80a9b2ab63f5ac8e0611d88 [file] [log] [blame]
preetham0202a15494c2025-02-13 13:18:14 +05301distribute result [$$125]
Yingyi Bu342bd342017-09-06 13:17:02 -07002-- DISTRIBUTE_RESULT |PARTITIONED|
preetham02023d3ece62025-01-20 14:04:42 -08003 exchange
Yingyi Bu342bd342017-09-06 13:17:02 -07004 -- ONE_TO_ONE_EXCHANGE |PARTITIONED|
preetham0202a15494c2025-02-13 13:18:14 +05305 assign [$$125] <- [{"l_returnflag": $$l_returnflag, "l_linestatus": $$l_linestatus, "count_cheaps": $$131, "count_expensives": $$132}] project: [$$125]
preetham020276744a32024-10-24 12:26:12 +05306 -- ASSIGN |PARTITIONED|
preetham0202a15494c2025-02-13 13:18:14 +05307 exchange
preetham020276744a32024-10-24 12:26:12 +05308 -- SORT_MERGE_EXCHANGE [$$l_returnflag(ASC), $$l_linestatus(ASC) ] |PARTITIONED|
preetham0202a15494c2025-02-13 13:18:14 +05309 group by ([$$l_returnflag := $$139; $$l_linestatus := $$140]) decor ([]) {
10 aggregate [$$131] <- [agg-sum($$137)]
11 -- AGGREGATE |LOCAL|
12 nested tuple source
13 -- NESTED_TUPLE_SOURCE |LOCAL|
14 }
15 {
16 aggregate [$$132] <- [agg-sum($$138)]
17 -- AGGREGATE |LOCAL|
18 nested tuple source
19 -- NESTED_TUPLE_SOURCE |LOCAL|
20 }
preetham020276744a32024-10-24 12:26:12 +053021 -- PRE_CLUSTERED_GROUP_BY[$$139, $$140] |PARTITIONED|
preetham0202a15494c2025-02-13 13:18:14 +053022 exchange
preetham020276744a32024-10-24 12:26:12 +053023 -- ONE_TO_ONE_EXCHANGE |PARTITIONED|
preetham0202a15494c2025-02-13 13:18:14 +053024 order (ASC, $$139) (ASC, $$140)
preetham020276744a32024-10-24 12:26:12 +053025 -- STABLE_SORT [$$139(ASC), $$140(ASC)] |PARTITIONED|
preetham0202a15494c2025-02-13 13:18:14 +053026 exchange
preetham020276744a32024-10-24 12:26:12 +053027 -- HASH_PARTITION_EXCHANGE [$$139, $$140] |PARTITIONED|
preetham0202a15494c2025-02-13 13:18:14 +053028 group by ([$$139 := $$126; $$140 := $$127]) decor ([]) {
29 aggregate [$$137] <- [agg-count($$l)]
30 -- AGGREGATE |LOCAL|
31 select (gt($$135, 0.05))
32 -- STREAM_SELECT |LOCAL|
33 nested tuple source
34 -- NESTED_TUPLE_SOURCE |LOCAL|
35 }
36 {
37 aggregate [$$138] <- [agg-count($$l)]
38 -- AGGREGATE |LOCAL|
39 select (le($$135, 0.05))
40 -- STREAM_SELECT |LOCAL|
41 nested tuple source
42 -- NESTED_TUPLE_SOURCE |LOCAL|
43 }
preetham020276744a32024-10-24 12:26:12 +053044 -- PRE_CLUSTERED_GROUP_BY[$$126, $$127] |PARTITIONED|
preetham0202a15494c2025-02-13 13:18:14 +053045 exchange
preetham020276744a32024-10-24 12:26:12 +053046 -- ONE_TO_ONE_EXCHANGE |PARTITIONED|
preetham0202a15494c2025-02-13 13:18:14 +053047 order (ASC, $$126) (ASC, $$127)
preetham020276744a32024-10-24 12:26:12 +053048 -- STABLE_SORT [$$126(ASC), $$127(ASC)] |PARTITIONED|
preetham0202a15494c2025-02-13 13:18:14 +053049 exchange
preetham020276744a32024-10-24 12:26:12 +053050 -- ONE_TO_ONE_EXCHANGE |PARTITIONED|
preetham0202a15494c2025-02-13 13:18:14 +053051 assign [$$127, $$126, $$135] <- [$$l.getField(9), $$l.getField(8), $$l.getField(6)]
preetham020276744a32024-10-24 12:26:12 +053052 -- ASSIGN |PARTITIONED|
preetham0202a15494c2025-02-13 13:18:14 +053053 project ([$$l])
preetham020276744a32024-10-24 12:26:12 +053054 -- STREAM_PROJECT |PARTITIONED|
preetham0202a15494c2025-02-13 13:18:14 +053055 exchange
preetham020276744a32024-10-24 12:26:12 +053056 -- ONE_TO_ONE_EXCHANGE |PARTITIONED|
preetham0202a15494c2025-02-13 13:18:14 +053057 data-scan []<-[$$129, $$130, $$l] <- tpch.LineItem
58 -- DATASOURCE_SCAN |PARTITIONED|
59 exchange
preetham020276744a32024-10-24 12:26:12 +053060 -- ONE_TO_ONE_EXCHANGE |PARTITIONED|
preetham0202a15494c2025-02-13 13:18:14 +053061 empty-tuple-source
preetham020276744a32024-10-24 12:26:12 +053062 -- EMPTY_TUPLE_SOURCE |PARTITIONED|