preetham0202 | a15494c | 2025-02-13 13:18:14 +0530 | [diff] [blame] | 1 | distribute result [$$125] |
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 | a15494c | 2025-02-13 13:18:14 +0530 | [diff] [blame] | 5 | assign [$$125] <- [{"l_returnflag": $$l_returnflag, "l_linestatus": $$l_linestatus, "count_cheaps": $$131, "count_expensives": $$132}] project: [$$125] |
preetham0202 | 76744a3 | 2024-10-24 12:26:12 +0530 | [diff] [blame] | 6 | -- ASSIGN |PARTITIONED| |
preetham0202 | a15494c | 2025-02-13 13:18:14 +0530 | [diff] [blame] | 7 | exchange |
preetham0202 | 76744a3 | 2024-10-24 12:26:12 +0530 | [diff] [blame] | 8 | -- SORT_MERGE_EXCHANGE [$$l_returnflag(ASC), $$l_linestatus(ASC) ] |PARTITIONED| |
preetham0202 | a15494c | 2025-02-13 13:18:14 +0530 | [diff] [blame] | 9 | 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 | } |
preetham0202 | 76744a3 | 2024-10-24 12:26:12 +0530 | [diff] [blame] | 21 | -- PRE_CLUSTERED_GROUP_BY[$$139, $$140] |PARTITIONED| |
preetham0202 | a15494c | 2025-02-13 13:18:14 +0530 | [diff] [blame] | 22 | exchange |
preetham0202 | 76744a3 | 2024-10-24 12:26:12 +0530 | [diff] [blame] | 23 | -- ONE_TO_ONE_EXCHANGE |PARTITIONED| |
preetham0202 | a15494c | 2025-02-13 13:18:14 +0530 | [diff] [blame] | 24 | order (ASC, $$139) (ASC, $$140) |
preetham0202 | 76744a3 | 2024-10-24 12:26:12 +0530 | [diff] [blame] | 25 | -- STABLE_SORT [$$139(ASC), $$140(ASC)] |PARTITIONED| |
preetham0202 | a15494c | 2025-02-13 13:18:14 +0530 | [diff] [blame] | 26 | exchange |
preetham0202 | 76744a3 | 2024-10-24 12:26:12 +0530 | [diff] [blame] | 27 | -- HASH_PARTITION_EXCHANGE [$$139, $$140] |PARTITIONED| |
preetham0202 | a15494c | 2025-02-13 13:18:14 +0530 | [diff] [blame] | 28 | 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 | } |
preetham0202 | 76744a3 | 2024-10-24 12:26:12 +0530 | [diff] [blame] | 44 | -- PRE_CLUSTERED_GROUP_BY[$$126, $$127] |PARTITIONED| |
preetham0202 | a15494c | 2025-02-13 13:18:14 +0530 | [diff] [blame] | 45 | exchange |
preetham0202 | 76744a3 | 2024-10-24 12:26:12 +0530 | [diff] [blame] | 46 | -- ONE_TO_ONE_EXCHANGE |PARTITIONED| |
preetham0202 | a15494c | 2025-02-13 13:18:14 +0530 | [diff] [blame] | 47 | order (ASC, $$126) (ASC, $$127) |
preetham0202 | 76744a3 | 2024-10-24 12:26:12 +0530 | [diff] [blame] | 48 | -- STABLE_SORT [$$126(ASC), $$127(ASC)] |PARTITIONED| |
preetham0202 | a15494c | 2025-02-13 13:18:14 +0530 | [diff] [blame] | 49 | exchange |
preetham0202 | 76744a3 | 2024-10-24 12:26:12 +0530 | [diff] [blame] | 50 | -- ONE_TO_ONE_EXCHANGE |PARTITIONED| |
preetham0202 | a15494c | 2025-02-13 13:18:14 +0530 | [diff] [blame] | 51 | assign [$$127, $$126, $$135] <- [$$l.getField(9), $$l.getField(8), $$l.getField(6)] |
preetham0202 | 76744a3 | 2024-10-24 12:26:12 +0530 | [diff] [blame] | 52 | -- ASSIGN |PARTITIONED| |
preetham0202 | a15494c | 2025-02-13 13:18:14 +0530 | [diff] [blame] | 53 | project ([$$l]) |
preetham0202 | 76744a3 | 2024-10-24 12:26:12 +0530 | [diff] [blame] | 54 | -- STREAM_PROJECT |PARTITIONED| |
preetham0202 | a15494c | 2025-02-13 13:18:14 +0530 | [diff] [blame] | 55 | exchange |
preetham0202 | 76744a3 | 2024-10-24 12:26:12 +0530 | [diff] [blame] | 56 | -- ONE_TO_ONE_EXCHANGE |PARTITIONED| |
preetham0202 | a15494c | 2025-02-13 13:18:14 +0530 | [diff] [blame] | 57 | data-scan []<-[$$129, $$130, $$l] <- tpch.LineItem |
| 58 | -- DATASOURCE_SCAN |PARTITIONED| |
| 59 | exchange |
preetham0202 | 76744a3 | 2024-10-24 12:26:12 +0530 | [diff] [blame] | 60 | -- ONE_TO_ONE_EXCHANGE |PARTITIONED| |
preetham0202 | a15494c | 2025-02-13 13:18:14 +0530 | [diff] [blame] | 61 | empty-tuple-source |
preetham0202 | 76744a3 | 2024-10-24 12:26:12 +0530 | [diff] [blame] | 62 | -- EMPTY_TUPLE_SOURCE |PARTITIONED| |