| == Optimized Execution Plan == |
| Sink(table=[default_catalog.default_database.MySink], fields=[a, b, c]) |
| +- TableSourceScan(table=[[default_catalog, default_database, MyTable]], fields=[a, b, c]) |
| |
| == Physical Execution Plan == |
| { |
| "nodes" : [ { |
| "id" : , |
| "type" : "Source: MyTable[]", |
| "pact" : "Data Source", |
| "contents" : "[]:TableSourceScan(table=[[default_catalog, default_database, MyTable]], fields=[a, b, c])", |
| "parallelism" : 1 |
| }, { |
| "id" : , |
| "type" : "Sink: MySink[]", |
| "pact" : "Data Sink", |
| "contents" : "[]:Sink(table=[default_catalog.default_database.MySink], fields=[a, b, c])", |
| "parallelism" : 1, |
| "predecessors" : [ { |
| "id" : , |
| "ship_strategy" : "FORWARD", |
| "side" : "second" |
| } ] |
| } ] |
| } |
