blob: a48666614de4df14aaba6a0f9b1ace23db94e824 [file] [log] [blame]
preetham02023d3ece62025-01-20 14:04:42 -08001distribute result [$$116]
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|
preetham02023d3ece62025-01-20 14:04:42 -08005 project ([$$116])
Yingyi Bu342bd342017-09-06 13:17:02 -07006 -- STREAM_PROJECT |PARTITIONED|
preetham02023d3ece62025-01-20 14:04:42 -08007 assign [$$116] <- [{"l_returnflag": $$l_returnflag, "l_linestatus": $$l_linestatus, "count_cheaps": $$122, "count_expensives": $$123}]
Yingyi Bu342bd342017-09-06 13:17:02 -07008 -- ASSIGN |PARTITIONED|
preetham02023d3ece62025-01-20 14:04:42 -08009 exchange
Yingyi Bu342bd342017-09-06 13:17:02 -070010 -- SORT_MERGE_EXCHANGE [$$l_returnflag(ASC), $$l_linestatus(ASC) ] |PARTITIONED|
preetham02023d3ece62025-01-20 14:04:42 -080011 group by ([$$l_returnflag := $$130; $$l_linestatus := $$131]) decor ([]) {
12 aggregate [$$122] <- [agg-sum($$128)]
13 -- AGGREGATE |LOCAL|
14 nested tuple source
15 -- NESTED_TUPLE_SOURCE |LOCAL|
16 }
17 {
18 aggregate [$$123] <- [agg-sum($$129)]
19 -- AGGREGATE |LOCAL|
20 nested tuple source
21 -- NESTED_TUPLE_SOURCE |LOCAL|
22 }
Dmitry Lychaginee1b3b02020-11-24 18:22:26 -080023 -- PRE_CLUSTERED_GROUP_BY[$$130, $$131] |PARTITIONED|
preetham02023d3ece62025-01-20 14:04:42 -080024 exchange
Yingyi Bu342bd342017-09-06 13:17:02 -070025 -- ONE_TO_ONE_EXCHANGE |PARTITIONED|
preetham02023d3ece62025-01-20 14:04:42 -080026 order (ASC, $$130) (ASC, $$131)
Dmitry Lychaginee1b3b02020-11-24 18:22:26 -080027 -- STABLE_SORT [$$130(ASC), $$131(ASC)] |PARTITIONED|
preetham02023d3ece62025-01-20 14:04:42 -080028 exchange
Dmitry Lychaginee1b3b02020-11-24 18:22:26 -080029 -- HASH_PARTITION_EXCHANGE [$$130, $$131] |PARTITIONED|
preetham02023d3ece62025-01-20 14:04:42 -080030 group by ([$$130 := $$117; $$131 := $$118]) decor ([]) {
31 aggregate [$$128] <- [agg-count($$l)]
32 -- AGGREGATE |LOCAL|
33 select (gt($$126, 0.05))
34 -- STREAM_SELECT |LOCAL|
35 nested tuple source
36 -- NESTED_TUPLE_SOURCE |LOCAL|
37 }
38 {
39 aggregate [$$129] <- [agg-count($$l)]
40 -- AGGREGATE |LOCAL|
41 select (le($$126, 0.05))
42 -- STREAM_SELECT |LOCAL|
43 nested tuple source
44 -- NESTED_TUPLE_SOURCE |LOCAL|
45 }
Dmitry Lychaginee1b3b02020-11-24 18:22:26 -080046 -- PRE_CLUSTERED_GROUP_BY[$$117, $$118] |PARTITIONED|
preetham02023d3ece62025-01-20 14:04:42 -080047 exchange
Yingyi Bu342bd342017-09-06 13:17:02 -070048 -- ONE_TO_ONE_EXCHANGE |PARTITIONED|
preetham02023d3ece62025-01-20 14:04:42 -080049 order (ASC, $$117) (ASC, $$118)
Dmitry Lychaginee1b3b02020-11-24 18:22:26 -080050 -- STABLE_SORT [$$117(ASC), $$118(ASC)] |PARTITIONED|
preetham02023d3ece62025-01-20 14:04:42 -080051 exchange
Yingyi Bu342bd342017-09-06 13:17:02 -070052 -- ONE_TO_ONE_EXCHANGE |PARTITIONED|
preetham02023d3ece62025-01-20 14:04:42 -080053 assign [$$118, $$117, $$126] <- [$$l.getField(9), $$l.getField(8), $$l.getField(6)]
Yingyi Bu342bd342017-09-06 13:17:02 -070054 -- ASSIGN |PARTITIONED|
preetham02023d3ece62025-01-20 14:04:42 -080055 project ([$$l])
Yingyi Bu342bd342017-09-06 13:17:02 -070056 -- STREAM_PROJECT |PARTITIONED|
preetham02023d3ece62025-01-20 14:04:42 -080057 exchange
Yingyi Bu342bd342017-09-06 13:17:02 -070058 -- ONE_TO_ONE_EXCHANGE |PARTITIONED|
preetham02023d3ece62025-01-20 14:04:42 -080059 data-scan []<-[$$120, $$121, $$l] <- tpch.LineItem
60 -- DATASOURCE_SCAN |PARTITIONED|
61 exchange
Yingyi Bu342bd342017-09-06 13:17:02 -070062 -- ONE_TO_ONE_EXCHANGE |PARTITIONED|
preetham02023d3ece62025-01-20 14:04:42 -080063 empty-tuple-source
Yingyi Bu342bd342017-09-06 13:17:02 -070064 -- EMPTY_TUPLE_SOURCE |PARTITIONED|