preetham0202 | 3d3ece6 | 2025-01-20 14:04:42 -0800 | [diff] [blame^] | 1 | distribute result [$$116] |
Yingyi Bu | 342bd34 | 2017-09-06 13:17:02 -0700 | [diff] [blame] | 2 | -- DISTRIBUTE_RESULT |PARTITIONED| |
preetham0202 | 3d3ece6 | 2025-01-20 14:04:42 -0800 | [diff] [blame^] | 3 | exchange |
Yingyi Bu | 342bd34 | 2017-09-06 13:17:02 -0700 | [diff] [blame] | 4 | -- ONE_TO_ONE_EXCHANGE |PARTITIONED| |
preetham0202 | 3d3ece6 | 2025-01-20 14:04:42 -0800 | [diff] [blame^] | 5 | project ([$$116]) |
Yingyi Bu | 342bd34 | 2017-09-06 13:17:02 -0700 | [diff] [blame] | 6 | -- STREAM_PROJECT |PARTITIONED| |
preetham0202 | 3d3ece6 | 2025-01-20 14:04:42 -0800 | [diff] [blame^] | 7 | assign [$$116] <- [{"l_returnflag": $$l_returnflag, "l_linestatus": $$l_linestatus, "count_cheaps": $$122, "count_expensives": $$123}] |
Yingyi Bu | 342bd34 | 2017-09-06 13:17:02 -0700 | [diff] [blame] | 8 | -- ASSIGN |PARTITIONED| |
preetham0202 | 3d3ece6 | 2025-01-20 14:04:42 -0800 | [diff] [blame^] | 9 | exchange |
Yingyi Bu | 342bd34 | 2017-09-06 13:17:02 -0700 | [diff] [blame] | 10 | -- SORT_MERGE_EXCHANGE [$$l_returnflag(ASC), $$l_linestatus(ASC) ] |PARTITIONED| |
preetham0202 | 3d3ece6 | 2025-01-20 14:04:42 -0800 | [diff] [blame^] | 11 | 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 Lychagin | ee1b3b0 | 2020-11-24 18:22:26 -0800 | [diff] [blame] | 23 | -- PRE_CLUSTERED_GROUP_BY[$$130, $$131] |PARTITIONED| |
preetham0202 | 3d3ece6 | 2025-01-20 14:04:42 -0800 | [diff] [blame^] | 24 | exchange |
Yingyi Bu | 342bd34 | 2017-09-06 13:17:02 -0700 | [diff] [blame] | 25 | -- ONE_TO_ONE_EXCHANGE |PARTITIONED| |
preetham0202 | 3d3ece6 | 2025-01-20 14:04:42 -0800 | [diff] [blame^] | 26 | order (ASC, $$130) (ASC, $$131) |
Dmitry Lychagin | ee1b3b0 | 2020-11-24 18:22:26 -0800 | [diff] [blame] | 27 | -- STABLE_SORT [$$130(ASC), $$131(ASC)] |PARTITIONED| |
preetham0202 | 3d3ece6 | 2025-01-20 14:04:42 -0800 | [diff] [blame^] | 28 | exchange |
Dmitry Lychagin | ee1b3b0 | 2020-11-24 18:22:26 -0800 | [diff] [blame] | 29 | -- HASH_PARTITION_EXCHANGE [$$130, $$131] |PARTITIONED| |
preetham0202 | 3d3ece6 | 2025-01-20 14:04:42 -0800 | [diff] [blame^] | 30 | 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 Lychagin | ee1b3b0 | 2020-11-24 18:22:26 -0800 | [diff] [blame] | 46 | -- PRE_CLUSTERED_GROUP_BY[$$117, $$118] |PARTITIONED| |
preetham0202 | 3d3ece6 | 2025-01-20 14:04:42 -0800 | [diff] [blame^] | 47 | exchange |
Yingyi Bu | 342bd34 | 2017-09-06 13:17:02 -0700 | [diff] [blame] | 48 | -- ONE_TO_ONE_EXCHANGE |PARTITIONED| |
preetham0202 | 3d3ece6 | 2025-01-20 14:04:42 -0800 | [diff] [blame^] | 49 | order (ASC, $$117) (ASC, $$118) |
Dmitry Lychagin | ee1b3b0 | 2020-11-24 18:22:26 -0800 | [diff] [blame] | 50 | -- STABLE_SORT [$$117(ASC), $$118(ASC)] |PARTITIONED| |
preetham0202 | 3d3ece6 | 2025-01-20 14:04:42 -0800 | [diff] [blame^] | 51 | exchange |
Yingyi Bu | 342bd34 | 2017-09-06 13:17:02 -0700 | [diff] [blame] | 52 | -- ONE_TO_ONE_EXCHANGE |PARTITIONED| |
preetham0202 | 3d3ece6 | 2025-01-20 14:04:42 -0800 | [diff] [blame^] | 53 | assign [$$118, $$117, $$126] <- [$$l.getField(9), $$l.getField(8), $$l.getField(6)] |
Yingyi Bu | 342bd34 | 2017-09-06 13:17:02 -0700 | [diff] [blame] | 54 | -- ASSIGN |PARTITIONED| |
preetham0202 | 3d3ece6 | 2025-01-20 14:04:42 -0800 | [diff] [blame^] | 55 | project ([$$l]) |
Yingyi Bu | 342bd34 | 2017-09-06 13:17:02 -0700 | [diff] [blame] | 56 | -- STREAM_PROJECT |PARTITIONED| |
preetham0202 | 3d3ece6 | 2025-01-20 14:04:42 -0800 | [diff] [blame^] | 57 | exchange |
Yingyi Bu | 342bd34 | 2017-09-06 13:17:02 -0700 | [diff] [blame] | 58 | -- ONE_TO_ONE_EXCHANGE |PARTITIONED| |
preetham0202 | 3d3ece6 | 2025-01-20 14:04:42 -0800 | [diff] [blame^] | 59 | data-scan []<-[$$120, $$121, $$l] <- tpch.LineItem |
| 60 | -- DATASOURCE_SCAN |PARTITIONED| |
| 61 | exchange |
Yingyi Bu | 342bd34 | 2017-09-06 13:17:02 -0700 | [diff] [blame] | 62 | -- ONE_TO_ONE_EXCHANGE |PARTITIONED| |
preetham0202 | 3d3ece6 | 2025-01-20 14:04:42 -0800 | [diff] [blame^] | 63 | empty-tuple-source |
Yingyi Bu | 342bd34 | 2017-09-06 13:17:02 -0700 | [diff] [blame] | 64 | -- EMPTY_TUPLE_SOURCE |PARTITIONED| |