testFileSystemTableSinkWithParallelismInStreamingSql0.out

== Abstract Syntax Tree ==
LogicalSink(table=[default_catalog.default_database.test_sink_table], fields=[id, real_col, double_col, decimal_col])
+- LogicalProject(id=[$0], real_col=[$1], double_col=[$2], decimal_col=[$3])
   +- LogicalTableScan(table=[[default_catalog, default_database, test_source_table]])

== Optimized Physical Plan ==
Sink(table=[default_catalog.default_database.test_sink_table], fields=[id, real_col, double_col, decimal_col])
+- TableSourceScan(table=[[default_catalog, default_database, test_source_table]], fields=[id, real_col, double_col, decimal_col])

== Optimized Execution Plan ==
Sink(table=[default_catalog.default_database.test_sink_table], fields=[id, real_col, double_col, decimal_col])
+- TableSourceScan(table=[[default_catalog, default_database, test_source_table]], fields=[id, real_col, double_col, decimal_col])

== Physical Execution Plan ==
{
  "nodes" : [ {
    "id" : ,
    "type" : "Source: TableSourceScan(table=[[default_catalog, default_database, test_source_table]], fields=[id, real_col, double_col, decimal_col])",
    "pact" : "Data Source",
    "contents" : "Source: TableSourceScan(table=[[default_catalog, default_database, test_source_table]], fields=[id, real_col, double_col, decimal_col])",
    "parallelism" : 1
  }, {
    "id" : ,
    "type" : "StreamingFileWriter",
    "pact" : "Operator",
    "contents" : "StreamingFileWriter",
    "parallelism" : 5,
    "predecessors" : [ {
      "id" : ,
      "ship_strategy" : "REBALANCE",
      "side" : "second"
    } ]
  }, {
    "id" : ,
    "type" : "Sink: end",
    "pact" : "Data Sink",
    "contents" : "Sink: end",
    "parallelism" : 1,
    "predecessors" : [ {
      "id" : ,
      "ship_strategy" : "REBALANCE",
      "side" : "second"
    } ]
  } ]
}