preetham0202 | 3d3ece6 | 2025-01-20 14:04:42 -0800 | [diff] [blame] | 1 | distribute result [$$42] |
ggalvizo | 21e5282 | 2021-07-27 10:26:31 -1000 | [diff] [blame] | 2 | -- DISTRIBUTE_RESULT |PARTITIONED| |
preetham0202 | 3d3ece6 | 2025-01-20 14:04:42 -0800 | [diff] [blame] | 3 | exchange |
ggalvizo | 21e5282 | 2021-07-27 10:26:31 -1000 | [diff] [blame] | 4 | -- ONE_TO_ONE_EXCHANGE |PARTITIONED| |
preetham0202 | 3d3ece6 | 2025-01-20 14:04:42 -0800 | [diff] [blame] | 5 | project ([$$42]) |
ggalvizo | 21e5282 | 2021-07-27 10:26:31 -1000 | [diff] [blame] | 6 | -- STREAM_PROJECT |PARTITIONED| |
preetham0202 | 3d3ece6 | 2025-01-20 14:04:42 -0800 | [diff] [blame] | 7 | assign [$$42] <- [{"D": $$D}] |
ggalvizo | 21e5282 | 2021-07-27 10:26:31 -1000 | [diff] [blame] | 8 | -- ASSIGN |PARTITIONED| |
preetham0202 | 3d3ece6 | 2025-01-20 14:04:42 -0800 | [diff] [blame] | 9 | project ([$$D]) |
ggalvizo | 21e5282 | 2021-07-27 10:26:31 -1000 | [diff] [blame] | 10 | -- STREAM_PROJECT |PARTITIONED| |
preetham0202 | 3d3ece6 | 2025-01-20 14:04:42 -0800 | [diff] [blame] | 11 | select (and($$38, eq($$39, 0))) |
ggalvizo | 21e5282 | 2021-07-27 10:26:31 -1000 | [diff] [blame] | 12 | -- STREAM_SELECT |PARTITIONED| |
preetham0202 | 3d3ece6 | 2025-01-20 14:04:42 -0800 | [diff] [blame] | 13 | project ([$$D, $$38, $$39]) |
ggalvizo | 21e5282 | 2021-07-27 10:26:31 -1000 | [diff] [blame] | 14 | -- STREAM_PROJECT |PARTITIONED| |
preetham0202 | 3d3ece6 | 2025-01-20 14:04:42 -0800 | [diff] [blame] | 15 | subplan { |
preetham0202 | 86e6336 | 2025-02-13 01:37:43 +0530 | [diff] [blame] | 16 | aggregate [$$38, $$39] <- [non-empty-stream(), agg-sql-count(switch-case(and($$35, eq($$36, 0)), true, null, true))] |
ggalvizo | 21e5282 | 2021-07-27 10:26:31 -1000 | [diff] [blame] | 17 | -- AGGREGATE |LOCAL| |
preetham0202 | 3d3ece6 | 2025-01-20 14:04:42 -0800 | [diff] [blame] | 18 | subplan { |
preetham0202 | 86e6336 | 2025-02-13 01:37:43 +0530 | [diff] [blame] | 19 | aggregate [$$35, $$36] <- [non-empty-stream(), agg-sql-count(switch-case(eq($$J, 1), true, null, true))] |
ggalvizo | 21e5282 | 2021-07-27 10:26:31 -1000 | [diff] [blame] | 20 | -- AGGREGATE |LOCAL| |
preetham0202 | 3d3ece6 | 2025-01-20 14:04:42 -0800 | [diff] [blame] | 21 | unnest $$J <- scan-collection($$45) |
ggalvizo | 21e5282 | 2021-07-27 10:26:31 -1000 | [diff] [blame] | 22 | -- UNNEST |LOCAL| |
preetham0202 | 3d3ece6 | 2025-01-20 14:04:42 -0800 | [diff] [blame] | 23 | nested tuple source |
ggalvizo | 21e5282 | 2021-07-27 10:26:31 -1000 | [diff] [blame] | 24 | -- NESTED_TUPLE_SOURCE |LOCAL| |
preetham0202 | 3d3ece6 | 2025-01-20 14:04:42 -0800 | [diff] [blame] | 25 | } |
| 26 | -- SUBPLAN |LOCAL| |
| 27 | assign [$$45] <- [$$I.getField("items")] |
ggalvizo | 21e5282 | 2021-07-27 10:26:31 -1000 | [diff] [blame] | 28 | -- ASSIGN |LOCAL| |
preetham0202 | 3d3ece6 | 2025-01-20 14:04:42 -0800 | [diff] [blame] | 29 | unnest $$I <- scan-collection($$44) |
ggalvizo | 21e5282 | 2021-07-27 10:26:31 -1000 | [diff] [blame] | 30 | -- UNNEST |LOCAL| |
preetham0202 | 3d3ece6 | 2025-01-20 14:04:42 -0800 | [diff] [blame] | 31 | nested tuple source |
ggalvizo | 21e5282 | 2021-07-27 10:26:31 -1000 | [diff] [blame] | 32 | -- NESTED_TUPLE_SOURCE |LOCAL| |
preetham0202 | 3d3ece6 | 2025-01-20 14:04:42 -0800 | [diff] [blame] | 33 | } |
| 34 | -- SUBPLAN |PARTITIONED| |
| 35 | assign [$$44] <- [$$D.getField("items")] |
ggalvizo | 21e5282 | 2021-07-27 10:26:31 -1000 | [diff] [blame] | 36 | -- ASSIGN |PARTITIONED| |
preetham0202 | 3d3ece6 | 2025-01-20 14:04:42 -0800 | [diff] [blame] | 37 | project ([$$D]) |
ggalvizo | 21e5282 | 2021-07-27 10:26:31 -1000 | [diff] [blame] | 38 | -- STREAM_PROJECT |PARTITIONED| |
preetham0202 | 3d3ece6 | 2025-01-20 14:04:42 -0800 | [diff] [blame] | 39 | exchange |
ggalvizo | 21e5282 | 2021-07-27 10:26:31 -1000 | [diff] [blame] | 40 | -- ONE_TO_ONE_EXCHANGE |PARTITIONED| |
preetham0202 | 3d3ece6 | 2025-01-20 14:04:42 -0800 | [diff] [blame] | 41 | data-scan []<-[$$43, $$D] <- TestDataverse.Dataset1 |
| 42 | -- DATASOURCE_SCAN |PARTITIONED| |
| 43 | exchange |
ggalvizo | 21e5282 | 2021-07-27 10:26:31 -1000 | [diff] [blame] | 44 | -- ONE_TO_ONE_EXCHANGE |PARTITIONED| |
preetham0202 | 3d3ece6 | 2025-01-20 14:04:42 -0800 | [diff] [blame] | 45 | empty-tuple-source |
| 46 | -- EMPTY_TUPLE_SOURCE |PARTITIONED| |