{
  "operator": "distribute-result",
  "expressions": [
    "$$20"
  ],
  "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": [
            "$$20"
          ],
          "operatorId": "1.3",
          "physical-operator": "STREAM_PROJECT",
          "execution-mode": "PARTITIONED",
          "inputs": [
            {
              "operator": "assign",
              "variables": [
                "$$20"
              ],
              "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",
                      "condition": "eq($$23, $$default_ds.getField(\"name\"))",
                      "operatorId": "1.6",
                      "physical-operator": "STREAM_SELECT",
                      "execution-mode": "PARTITIONED",
                      "inputs": [
                        {
                          "operator": "select",
                          "condition": "eq($$default_ds.getField(\"age\"), 70)",
                          "operatorId": "1.7",
                          "physical-operator": "STREAM_SELECT",
                          "execution-mode": "PARTITIONED",
                          "inputs": [
                            {
                              "operator": "project",
                              "variables": [
                                "$$23",
                                "$$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": [
                                        "$$21",
                                        "$$default_ds",
                                        "$$22"
                                      ],
                                      "expressions": [
                                        "index-search(\"default_ds\", 0, \"Default\", \"default_ds\", TRUE, FALSE, 1, $$27, 1, $$27, 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",
                                              "order-by-list": [
                                                {
                                                  "order": "ASC",
                                                  "expression": "$$27"
                                                }
                                              ],
                                              "operatorId": "1.12",
                                              "physical-operator": "STABLE_SORT [$$27(ASC)]",
                                              "execution-mode": "PARTITIONED",
                                              "inputs": [
                                                {
                                                  "operator": "exchange",
                                                  "operatorId": "1.13",
                                                  "physical-operator": "ONE_TO_ONE_EXCHANGE",
                                                  "execution-mode": "PARTITIONED",
                                                  "inputs": [
                                                    {
                                                      "operator": "project",
                                                      "variables": [
                                                        "$$23",
                                                        "$$27"
                                                      ],
                                                      "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": [
                                                                "$$25",
                                                                "$$26",
                                                                "$$27"
                                                              ],
                                                              "expressions": [
                                                                "index-search(\"default_idx1\", 0, \"Default\", \"default_ds\", TRUE, TRUE, 1, $$23, 1, $$23, 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": [
                                                                        "$$23"
                                                                      ],
                                                                      "expressions": [
                                                                        "scan-collection(array: [ \"pymc100161\", \"pymc100060\" ])"
                                                                      ],
                                                                      "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"
                                                                        }
                                                                      ]
                                                                    }
                                                                  ]
                                                                }
                                                              ]
                                                            }
                                                          ]
                                                        }
                                                      ]
                                                    }
                                                  ]
                                                }
                                              ]
                                            }
                                          ]
                                        }
                                      ]
                                    }
                                  ]
                                }
                              ]
                            }
                          ]
                        }
                      ]
                    }
                  ]
                }
              ]
            }
          ]
        }
      ]
    }
  ]
}