== Abstract Syntax Tree == LogicalLegacySink(name=[`default_catalog`.`default_database`.`MySink1`], fields=[first]) +- LogicalProject(first=[$0]) +- LogicalTableScan(table=[[default_catalog, default_database, MyTable, source: [CsvTableSource(read fields: first, id, score, last)]]]) LogicalLegacySink(name=[`default_catalog`.`default_database`.`MySink2`], fields=[last]) +- LogicalProject(last=[$3]) +- LogicalTableScan(table=[[default_catalog, default_database, MyTable, source: [CsvTableSource(read fields: first, id, score, last)]]]) == Optimized Logical Plan == LegacySink(name=[`default_catalog`.`default_database`.`MySink1`], fields=[first]) +- LegacyTableSourceScan(table=[[default_catalog, default_database, MyTable, source: [CsvTableSource(read fields: first)]]], fields=[first]) LegacySink(name=[`default_catalog`.`default_database`.`MySink2`], fields=[last]) +- LegacyTableSourceScan(table=[[default_catalog, default_database, MyTable, source: [CsvTableSource(read fields: last)]]], fields=[last]) == Physical Execution Plan == : Data Source content : Source: Custom File source : Operator content : CsvTableSource(read fields: first) ship_strategy : REBALANCE : Operator content : SourceConversion(table=[default_catalog.default_database.MyTable, source: [CsvTableSource(read fields: first)]], fields=[first]) ship_strategy : FORWARD : Operator content : SinkConversionToRow ship_strategy : FORWARD : Operator content : Map ship_strategy : REBALANCE : Data Source content : Source: Custom File source : Operator content : CsvTableSource(read fields: last) ship_strategy : REBALANCE : Operator content : SourceConversion(table=[default_catalog.default_database.MyTable, source: [CsvTableSource(read fields: last)]], fields=[last]) ship_strategy : FORWARD : Operator content : SinkConversionToRow ship_strategy : FORWARD : Operator content : Map ship_strategy : REBALANCE : Data Sink content : Sink: CsvTableSink(first) ship_strategy : FORWARD : Data Sink content : Sink: CsvTableSink(last) ship_strategy : FORWARD