{ "operator": "distribute-result", "expressions": [ "$$65" ], "operatorId": "1.1", "physical-operator": "DISTRIBUTE_RESULT", "execution-mode": "PARTITIONED", "inputs": [ { "operator": "exchange", "operatorId": "1.2", "physical-operator": "ONE_TO_ONE_EXCHANGE", "execution-mode": "PARTITIONED", "inputs": [ { "operator": "project", "variables": [ "$$65" ], "operatorId": "1.3", "physical-operator": "STREAM_PROJECT", "execution-mode": "PARTITIONED", "inputs": [ { "operator": "assign", "variables": [ "$$65" ], "expressions": [ "{\"o_ol_cnt\": $$o_ol_cnt, \"order_COUNT\": $$71}" ], "operatorId": "1.4", "physical-operator": "ASSIGN", "execution-mode": "PARTITIONED", "inputs": [ { "operator": "exchange", "operatorId": "1.5", "physical-operator": "SORT_MERGE_EXCHANGE [$$o_ol_cnt(ASC) ]", "execution-mode": "PARTITIONED", "inputs": [ { "operator": "group-by", "group-by-list": [ { "variable": "$$o_ol_cnt", "expression": "$$76" } ], "subplan": [ { "operator": "aggregate", "variables": [ "$$71" ], "expressions": [ "agg-sql-sum($$75)" ], "operatorId": "1.5.1", "physical-operator": "AGGREGATE", "execution-mode": "LOCAL", "inputs": [ { "operator": "nested-tuple-source", "operatorId": "1.5.2", "physical-operator": "NESTED_TUPLE_SOURCE", "execution-mode": "LOCAL" } ] } ], "operatorId": "1.6", "physical-operator": "SORT_GROUP_BY[$$76]", "execution-mode": "PARTITIONED", "inputs": [ { "operator": "exchange", "operatorId": "1.7", "physical-operator": "HASH_PARTITION_EXCHANGE [$$76]", "execution-mode": "PARTITIONED", "inputs": [ { "operator": "group-by", "group-by-list": [ { "variable": "$$76", "expression": "$$66" } ], "subplan": [ { "operator": "aggregate", "variables": [ "$$75" ], "expressions": [ "agg-sql-count(1)" ], "operatorId": "1.7.1", "physical-operator": "AGGREGATE", "execution-mode": "LOCAL", "inputs": [ { "operator": "nested-tuple-source", "operatorId": "1.7.2", "physical-operator": "NESTED_TUPLE_SOURCE", "execution-mode": "LOCAL" } ] } ], "operatorId": "1.8", "physical-operator": "SORT_GROUP_BY[$$66]", "execution-mode": "PARTITIONED", "inputs": [ { "operator": "exchange", "operatorId": "1.9", "physical-operator": "ONE_TO_ONE_EXCHANGE", "execution-mode": "PARTITIONED", "inputs": [ { "operator": "project", "variables": [ "$$66" ], "operatorId": "1.10", "physical-operator": "STREAM_PROJECT", "execution-mode": "PARTITIONED", "inputs": [ { "operator": "select", "condition": "neq($$70, 0)", "operatorId": "1.11", "physical-operator": "STREAM_SELECT", "execution-mode": "PARTITIONED", "inputs": [ { "operator": "project", "variables": [ "$$66", "$$70" ], "operatorId": "1.12", "physical-operator": "STREAM_PROJECT", "execution-mode": "PARTITIONED", "inputs": [ { "subplan": [ { "operator": "aggregate", "variables": [ "$$70" ], "expressions": [ "agg-count(1)" ], "operatorId": "1.12.1", "physical-operator": "AGGREGATE", "execution-mode": "LOCAL", "inputs": [ { "operator": "select", "condition": "ge($$73, date-add-str($$74, 1, \"week\"))", "operatorId": "1.12.2", "physical-operator": "STREAM_SELECT", "execution-mode": "LOCAL", "inputs": [ { "operator": "assign", "variables": [ "$$73" ], "expressions": [ "$$ol.getField(\"ol_delivery_d\")" ], "operatorId": "1.12.3", "physical-operator": "ASSIGN", "execution-mode": "LOCAL", "inputs": [ { "operator": "unnest", "variables": [ "$$ol" ], "expressions": [ "scan-collection($$72)" ], "operatorId": "1.12.4", "physical-operator": "UNNEST", "execution-mode": "LOCAL", "inputs": [ { "operator": "nested-tuple-source", "operatorId": "1.12.5", "physical-operator": "NESTED_TUPLE_SOURCE", "execution-mode": "LOCAL" } ] } ] } ] } ] } ], "operatorId": "1.13", "physical-operator": "SUBPLAN", "execution-mode": "PARTITIONED", "inputs": [ { "operator": "select", "condition": "and(lt($$74, \"2015-10-01 00:00:00.000000\"), ge($$74, \"2015-07-01 00:00:00.000000\"))", "operatorId": "1.14", "physical-operator": "STREAM_SELECT", "execution-mode": "PARTITIONED", "inputs": [ { "operator": "project", "variables": [ "$$66", "$$74", "$$72" ], "operatorId": "1.15", "physical-operator": "STREAM_PROJECT", "execution-mode": "PARTITIONED", "inputs": [ { "operator": "assign", "variables": [ "$$66", "$$74", "$$72" ], "expressions": [ "$$o.getField(\"o_ol_cnt\")", "$$o.getField(\"o_entry_d\")", "$$o.getField(\"orderline\")" ], "operatorId": "1.16", "physical-operator": "ASSIGN", "execution-mode": "PARTITIONED", "inputs": [ { "operator": "project", "variables": [ "$$o" ], "operatorId": "1.17", "physical-operator": "STREAM_PROJECT", "execution-mode": "PARTITIONED", "inputs": [ { "operator": "exchange", "operatorId": "1.18", "physical-operator": "ONE_TO_ONE_EXCHANGE", "execution-mode": "PARTITIONED", "inputs": [ { "operator": "unnest-map", "variables": [ "$$68", "$$o", "$$69" ], "expressions": [ "index-search(\"orders\", 0, \"Default\", \"orders\", FALSE, FALSE, 1, $$80, 1, $$80, TRUE, TRUE, TRUE)" ], "operatorId": "1.19", "physical-operator": "BTREE_SEARCH", "execution-mode": "PARTITIONED", "inputs": [ { "operator": "exchange", "operatorId": "1.20", "physical-operator": "ONE_TO_ONE_EXCHANGE", "execution-mode": "PARTITIONED", "inputs": [ { "operator": "order", "order-by-list": [ { "order": "ASC", "expression": "$$80" } ], "operatorId": "1.21", "physical-operator": "STABLE_SORT [$$80(ASC)]", "execution-mode": "PARTITIONED", "inputs": [ { "operator": "exchange", "operatorId": "1.22", "physical-operator": "ONE_TO_ONE_EXCHANGE", "execution-mode": "PARTITIONED", "inputs": [ { "operator": "project", "variables": [ "$$80" ], "operatorId": "1.23", "physical-operator": "STREAM_PROJECT", "execution-mode": "PARTITIONED", "inputs": [ { "operator": "exchange", "operatorId": "1.24", "physical-operator": "ONE_TO_ONE_EXCHANGE", "execution-mode": "PARTITIONED", "inputs": [ { "operator": "unnest-map", "variables": [ "$$79", "$$80" ], "expressions": [ "index-search(\"entrydate\", 0, \"Default\", \"orders\", FALSE, FALSE, 1, $$77, 1, $$78, TRUE, FALSE, FALSE)" ], "operatorId": "1.25", "physical-operator": "BTREE_SEARCH", "execution-mode": "PARTITIONED", "inputs": [ { "operator": "exchange", "operatorId": "1.26", "physical-operator": "ONE_TO_ONE_EXCHANGE", "execution-mode": "PARTITIONED", "inputs": [ { "operator": "assign", "variables": [ "$$77", "$$78" ], "expressions": [ "\"2015-07-01 00:00:00.000000\"", "\"2015-10-01 00:00:00.000000\"" ], "operatorId": "1.27", "physical-operator": "ASSIGN", "execution-mode": "PARTITIONED", "inputs": [ { "operator": "empty-tuple-source", "operatorId": "1.28", "physical-operator": "EMPTY_TUPLE_SOURCE", "execution-mode": "PARTITIONED" } ] } ] } ] } ] } ] } ] } ] } ] } ] } ] } ] } ] } ] } ] } ] } ] } ] } ] } ] } ] } ] } ] } ] } ] } ] } ] } ] }