{
  "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": "exchange",
                      "operatorId": "1.6",
                      "physical-operator": "ONE_TO_ONE_EXCHANGE",
                      "execution-mode": "PARTITIONED",
                      "inputs": [
                        {
                          "operator": "join",
                          "condition": "eq($$23, $$16)",
                          "operatorId": "1.7",
                          "physical-operator": "HYBRID_HASH_JOIN [$$16][$$23]",
                          "execution-mode": "PARTITIONED",
                          "inputs": [
                            {
                              "operator": "exchange",
                              "operatorId": "1.8",
                              "physical-operator": "ONE_TO_ONE_EXCHANGE",
                              "execution-mode": "PARTITIONED",
                              "inputs": [
                                {
                                  "operator": "select",
                                  "condition": "eq($$default_ds.getField(\"age\"), 70)",
                                  "operatorId": "1.9",
                                  "physical-operator": "STREAM_SELECT",
                                  "execution-mode": "PARTITIONED",
                                  "inputs": [
                                    {
                                      "operator": "assign",
                                      "variables": [
                                        "$$16"
                                      ],
                                      "expressions": [
                                        "$$default_ds.getField(\"name\")"
                                      ],
                                      "operatorId": "1.10",
                                      "physical-operator": "ASSIGN",
                                      "execution-mode": "PARTITIONED",
                                      "inputs": [
                                        {
                                          "operator": "project",
                                          "variables": [
                                            "$$default_ds"
                                          ],
                                          "operatorId": "1.11",
                                          "physical-operator": "STREAM_PROJECT",
                                          "execution-mode": "PARTITIONED",
                                          "inputs": [
                                            {
                                              "operator": "exchange",
                                              "operatorId": "1.12",
                                              "physical-operator": "ONE_TO_ONE_EXCHANGE",
                                              "execution-mode": "PARTITIONED",
                                              "inputs": [
                                                {
                                                  "operator": "data-scan",
                                                  "variables": [
                                                    "$$21",
                                                    "$$default_ds",
                                                    "$$22"
                                                  ],
                                                  "data-source": "Default.default_ds",
                                                  "operatorId": "1.13",
                                                  "physical-operator": "DATASOURCE_SCAN",
                                                  "execution-mode": "PARTITIONED",
                                                  "inputs": [
                                                    {
                                                      "operator": "exchange",
                                                      "operatorId": "1.14",
                                                      "physical-operator": "ONE_TO_ONE_EXCHANGE",
                                                      "execution-mode": "PARTITIONED",
                                                      "inputs": [
                                                        {
                                                          "operator": "empty-tuple-source",
                                                          "operatorId": "1.15",
                                                          "physical-operator": "EMPTY_TUPLE_SOURCE",
                                                          "execution-mode": "PARTITIONED"
                                                        }
                                                      ]
                                                    }
                                                  ]
                                                }
                                              ]
                                            }
                                          ]
                                        }
                                      ]
                                    }
                                  ]
                                }
                              ]
                            },
                            {
                              "operator": "exchange",
                              "operatorId": "1.16",
                              "physical-operator": "BROADCAST_EXCHANGE",
                              "execution-mode": "PARTITIONED",
                              "inputs": [
                                {
                                  "operator": "unnest",
                                  "variables": [
                                    "$$23"
                                  ],
                                  "expressions": [
                                    "scan-collection(array: [ \"pymc100161\", \"pymc100060\" ])"
                                  ],
                                  "operatorId": "1.17",
                                  "physical-operator": "UNNEST",
                                  "execution-mode": "UNPARTITIONED",
                                  "inputs": [
                                    {
                                      "operator": "empty-tuple-source",
                                      "operatorId": "1.18",
                                      "physical-operator": "EMPTY_TUPLE_SOURCE",
                                      "execution-mode": "UNPARTITIONED"
                                    }
                                  ]
                                }
                              ]
                            }
                          ]
                        }
                      ]
                    }
                  ]
                }
              ]
            }
          ]
        }
      ]
    }
  ]
}