flink-table/flink-table-planner/src/test/resources/explain/testStatementSetExecutionExplain.out

== Abstract Syntax Tree ==
LogicalSink(table=[default_catalog.default_database.MySink], fields=[last])
+- LogicalProject(last=[$3])
   +- LogicalTableScan(table=[[default_catalog, default_database, MyTable, source: [CsvTableSource(read fields: first, id, score, last)]]])

LogicalSink(table=[default_catalog.default_database.MySink], fields=[first])
+- LogicalProject(first=[$0])
   +- LogicalTableScan(table=[[default_catalog, default_database, MyTable, source: [CsvTableSource(read fields: first, id, score, last)]]])

== Optimized Physical Plan ==
Sink(table=[default_catalog.default_database.MySink], fields=[last])
+- Union(all=[true], union=[last])
   :- LegacyTableSourceScan(table=[[default_catalog, default_database, MyTable, source: [CsvTableSource(read fields: last)]]], fields=[last])
   +- LegacyTableSourceScan(table=[[default_catalog, default_database, MyTable, source: [CsvTableSource(read fields: first)]]], fields=[first])

== Optimized Execution Plan ==
Sink(table=[default_catalog.default_database.MySink], fields=[last])
+- Union(all=[true], union=[last])
   :- LegacyTableSourceScan(table=[[default_catalog, default_database, MyTable, source: [CsvTableSource(read fields: last)]]], fields=[last])
   +- LegacyTableSourceScan(table=[[default_catalog, default_database, MyTable, source: [CsvTableSource(read fields: first)]]], fields=[first])

== Physical Execution Plan ==
{
  "nodes" : [ {
    "id" : ,
    "type" : "Source: Custom File source",
    "pact" : "Data Source",
    "contents" : "Source: Custom File source",
    "parallelism" : 1
  }, {
    "id" : ,
    "type" : "CsvTableSource(read fields: last)",
    "pact" : "Operator",
    "contents" : "CsvTableSource(read fields: last)",
    "parallelism" : 1,
    "predecessors" : [ {
      "id" : ,
      "ship_strategy" : "FORWARD",
      "side" : "second"
    } ]
  }, {
    "id" : ,
    "type" : "SourceConversion[]",
    "pact" : "Operator",
    "contents" : "[]:SourceConversion(table=[default_catalog.default_database.MyTable, source: [CsvTableSource(read fields: last)]], fields=[last])",
    "parallelism" : 1,
    "predecessors" : [ {
      "id" : ,
      "ship_strategy" : "FORWARD",
      "side" : "second"
    } ]
  }, {
    "id" : ,
    "type" : "Source: Custom File source",
    "pact" : "Data Source",
    "contents" : "Source: Custom File source",
    "parallelism" : 1
  }, {
    "id" : ,
    "type" : "CsvTableSource(read fields: first)",
    "pact" : "Operator",
    "contents" : "CsvTableSource(read fields: first)",
    "parallelism" : 1,
    "predecessors" : [ {
      "id" : ,
      "ship_strategy" : "FORWARD",
      "side" : "second"
    } ]
  }, {
    "id" : ,
    "type" : "SourceConversion[]",
    "pact" : "Operator",
    "contents" : "[]:SourceConversion(table=[default_catalog.default_database.MyTable, source: [CsvTableSource(read fields: first)]], fields=[first])",
    "parallelism" : 1,
    "predecessors" : [ {
      "id" : ,
      "ship_strategy" : "FORWARD",
      "side" : "second"
    } ]
  }, {
    "id" : ,
    "type" : "StreamingFileWriter",
    "pact" : "Operator",
    "contents" : "StreamingFileWriter",
    "parallelism" : 1,
    "predecessors" : [ {
      "id" : ,
      "ship_strategy" : "FORWARD",
      "side" : "second"
    }, {
      "id" : ,
      "ship_strategy" : "FORWARD",
      "side" : "second"
    } ]
  }, {
    "id" : ,
    "type" : "end: Writer",
    "pact" : "Operator",
    "contents" : "end: Writer",
    "parallelism" : 1,
    "predecessors" : [ {
      "id" : ,
      "ship_strategy" : "FORWARD",
      "side" : "second"
    } ]
  } ]
}