{
  "operator": "distribute-result",
  "expressions": "$$19",
  "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": [
            "$$19"
          ],
          "operatorId": "1.3",
          "physical-operator": "STREAM_PROJECT",
          "execution-mode": "PARTITIONED",
          "inputs": [
            {
              "operator": "assign",
              "variables": [
                "$$19"
              ],
              "expressions": "{ default_ds : $$default_ds}",
              "operatorId": "1.4",
              "physical-operator": "ASSIGN",
              "execution-mode": "PARTITIONED",
              "inputs": [
                {
                  "operator": "project",
                  "variables": [
                    "$$default_ds"
                  ],
                  "operatorId": "1.5",
                  "physical-operator": "STREAM_PROJECT",
                  "execution-mode": "PARTITIONED",
                  "inputs": [
                    {
                      "operator": "select",
                      "expressions": "eq($$22, $$default_ds.getField( name ))",
                      "operatorId": "1.6",
                      "physical-operator": "STREAM_SELECT",
                      "execution-mode": "PARTITIONED",
                      "inputs": [
                        {
                          "operator": "select",
                          "expressions": "eq($$default_ds.getField( age ), 70)",
                          "operatorId": "1.7",
                          "physical-operator": "STREAM_SELECT",
                          "execution-mode": "PARTITIONED",
                          "inputs": [
                            {
                              "operator": "project",
                              "variables": [
                                "$$22",
                                "$$default_ds"
                              ],
                              "operatorId": "1.8",
                              "physical-operator": "STREAM_PROJECT",
                              "execution-mode": "PARTITIONED",
                              "inputs": [
                                {
                                  "operator": "exchange",
                                  "operatorId": "1.9",
                                  "physical-operator": "ONE_TO_ONE_EXCHANGE",
                                  "execution-mode": "PARTITIONED",
                                  "inputs": [
                                    {
                                      "operator": "unnest-map",
                                      "variables": [
                                        "$$20",
                                        "$$default_ds",
                                        "$$21"
                                      ],
                                      "expressions": "index-search( default_ds , 0,  Default ,  default_ds , TRUE, FALSE, 1, $$26, 1, $$26, TRUE, TRUE, TRUE)",
                                      "operatorId": "1.10",
                                      "physical-operator": "BTREE_SEARCH",
                                      "execution-mode": "PARTITIONED",
                                      "inputs": [
                                        {
                                          "operator": "exchange",
                                          "operatorId": "1.11",
                                          "physical-operator": "ONE_TO_ONE_EXCHANGE",
                                          "execution-mode": "PARTITIONED",
                                          "inputs": [
                                            {
                                              "operator": "order",
                                              "first": "ASC",
                                              "second": "$$26",
                                              "operatorId": "1.12",
                                              "physical-operator": "STABLE_SORT [$$26(ASC)]",
                                              "execution-mode": "PARTITIONED",
                                              "inputs": [
                                                {
                                                  "operator": "exchange",
                                                  "operatorId": "1.13",
                                                  "physical-operator": "ONE_TO_ONE_EXCHANGE",
                                                  "execution-mode": "PARTITIONED",
                                                  "inputs": [
                                                    {
                                                      "operator": "project",
                                                      "variables": [
                                                        "$$22",
                                                        "$$26"
                                                      ],
                                                      "operatorId": "1.14",
                                                      "physical-operator": "STREAM_PROJECT",
                                                      "execution-mode": "PARTITIONED",
                                                      "inputs": [
                                                        {
                                                          "operator": "exchange",
                                                          "operatorId": "1.15",
                                                          "physical-operator": "ONE_TO_ONE_EXCHANGE",
                                                          "execution-mode": "PARTITIONED",
                                                          "inputs": [
                                                            {
                                                              "operator": "unnest-map",
                                                              "variables": [
                                                                "$$24",
                                                                "$$25",
                                                                "$$26"
                                                              ],
                                                              "expressions": "index-search( default_idx1 , 0,  Default ,  default_ds , TRUE, TRUE, 1, $$22, 1, $$22, TRUE, TRUE, TRUE)",
                                                              "operatorId": "1.16",
                                                              "physical-operator": "BTREE_SEARCH",
                                                              "execution-mode": "PARTITIONED",
                                                              "inputs": [
                                                                {
                                                                  "operator": "exchange",
                                                                  "operatorId": "1.17",
                                                                  "physical-operator": "BROADCAST_EXCHANGE",
                                                                  "execution-mode": "PARTITIONED",
                                                                  "inputs": [
                                                                    {
                                                                      "operator": "unnest",
                                                                      "variables": [
                                                                        "$$22"
                                                                      ],
                                                                      "expressions": "scan-collection(array: [  pymc272 ,  pymc171  ])",
                                                                      "operatorId": "1.18",
                                                                      "physical-operator": "UNNEST",
                                                                      "execution-mode": "UNPARTITIONED",
                                                                      "inputs": [
                                                                        {
                                                                          "operator": "empty-tuple-source",
                                                                          "operatorId": "1.19",
                                                                          "physical-operator": "EMPTY_TUPLE_SOURCE",
                                                                          "execution-mode": "UNPARTITIONED"
                                                                        }
                                                                      ]
                                                                    }
                                                                  ]
                                                                }
                                                              ]
                                                            }
                                                          ]
                                                        }
                                                      ]
                                                    }
                                                  ]
                                                }
                                              ]
                                            }
                                          ]
                                        }
                                      ]
                                    }
                                  ]
                                }
                              ]
                            }
                          ]
                        }
                      ]
                    }
                  ]
                }
              ]
            }
          ]
        }
      ]
    }
  ]
}