blob: 009c55afb2544573a2d6ea810f7ae95cf7b2b8ca [file] [log] [blame]
preetham02023d3ece62025-01-20 14:04:42 -08001distribute result [$$42]
ggalvizo21e52822021-07-27 10:26:31 -10002-- DISTRIBUTE_RESULT |PARTITIONED|
preetham02023d3ece62025-01-20 14:04:42 -08003 exchange
ggalvizo21e52822021-07-27 10:26:31 -10004 -- ONE_TO_ONE_EXCHANGE |PARTITIONED|
preetham02023d3ece62025-01-20 14:04:42 -08005 project ([$$42])
ggalvizo21e52822021-07-27 10:26:31 -10006 -- STREAM_PROJECT |PARTITIONED|
preetham02023d3ece62025-01-20 14:04:42 -08007 assign [$$42] <- [{"D": $$D}]
ggalvizo21e52822021-07-27 10:26:31 -10008 -- ASSIGN |PARTITIONED|
preetham02023d3ece62025-01-20 14:04:42 -08009 project ([$$D])
ggalvizo21e52822021-07-27 10:26:31 -100010 -- STREAM_PROJECT |PARTITIONED|
preetham02023d3ece62025-01-20 14:04:42 -080011 select (and($$38, eq($$39, 0)))
ggalvizo21e52822021-07-27 10:26:31 -100012 -- STREAM_SELECT |PARTITIONED|
preetham02023d3ece62025-01-20 14:04:42 -080013 project ([$$D, $$38, $$39])
ggalvizo21e52822021-07-27 10:26:31 -100014 -- STREAM_PROJECT |PARTITIONED|
preetham02023d3ece62025-01-20 14:04:42 -080015 subplan {
preetham020286e63362025-02-13 01:37:43 +053016 aggregate [$$38, $$39] <- [non-empty-stream(), agg-sql-count(switch-case(and($$35, eq($$36, 0)), true, null, true))]
ggalvizo21e52822021-07-27 10:26:31 -100017 -- AGGREGATE |LOCAL|
preetham02023d3ece62025-01-20 14:04:42 -080018 subplan {
preetham020286e63362025-02-13 01:37:43 +053019 aggregate [$$35, $$36] <- [non-empty-stream(), agg-sql-count(switch-case(eq($$J, 1), true, null, true))]
ggalvizo21e52822021-07-27 10:26:31 -100020 -- AGGREGATE |LOCAL|
preetham02023d3ece62025-01-20 14:04:42 -080021 unnest $$J <- scan-collection($$45)
ggalvizo21e52822021-07-27 10:26:31 -100022 -- UNNEST |LOCAL|
preetham02023d3ece62025-01-20 14:04:42 -080023 nested tuple source
ggalvizo21e52822021-07-27 10:26:31 -100024 -- NESTED_TUPLE_SOURCE |LOCAL|
preetham02023d3ece62025-01-20 14:04:42 -080025 }
26 -- SUBPLAN |LOCAL|
27 assign [$$45] <- [$$I.getField("items")]
ggalvizo21e52822021-07-27 10:26:31 -100028 -- ASSIGN |LOCAL|
preetham02023d3ece62025-01-20 14:04:42 -080029 unnest $$I <- scan-collection($$44)
ggalvizo21e52822021-07-27 10:26:31 -100030 -- UNNEST |LOCAL|
preetham02023d3ece62025-01-20 14:04:42 -080031 nested tuple source
ggalvizo21e52822021-07-27 10:26:31 -100032 -- NESTED_TUPLE_SOURCE |LOCAL|
preetham02023d3ece62025-01-20 14:04:42 -080033 }
34 -- SUBPLAN |PARTITIONED|
35 assign [$$44] <- [$$D.getField("items")]
ggalvizo21e52822021-07-27 10:26:31 -100036 -- ASSIGN |PARTITIONED|
preetham02023d3ece62025-01-20 14:04:42 -080037 project ([$$D])
ggalvizo21e52822021-07-27 10:26:31 -100038 -- STREAM_PROJECT |PARTITIONED|
preetham02023d3ece62025-01-20 14:04:42 -080039 exchange
ggalvizo21e52822021-07-27 10:26:31 -100040 -- ONE_TO_ONE_EXCHANGE |PARTITIONED|
preetham02023d3ece62025-01-20 14:04:42 -080041 data-scan []<-[$$43, $$D] <- TestDataverse.Dataset1
42 -- DATASOURCE_SCAN |PARTITIONED|
43 exchange
ggalvizo21e52822021-07-27 10:26:31 -100044 -- ONE_TO_ONE_EXCHANGE |PARTITIONED|
preetham02023d3ece62025-01-20 14:04:42 -080045 empty-tuple-source
46 -- EMPTY_TUPLE_SOURCE |PARTITIONED|