| == Abstract Syntax Tree == |
| LogicalUnion(all=[true]) |
| LogicalTableScan(table=[[_DataStreamTable_0]]) |
| LogicalTableScan(table=[[_DataStreamTable_1]]) |
| |
| == Optimized Logical Plan == |
| DataStreamUnion(all=[true], union all=[count, word]) |
| DataStreamScan(table=[[_DataStreamTable_0]]) |
| DataStreamScan(table=[[_DataStreamTable_1]]) |
| |
| == Physical Execution Plan == |
| Stage 1 : Data Source |
| content : collect elements with CollectionInputFormat |
| |
| Stage 2 : Data Source |
| content : collect elements with CollectionInputFormat |
| |
| Stage 3 : Operator |
| content : from: (count, word) |
| ship_strategy : REBALANCE |
| |
| Stage 4 : Operator |
| content : from: (count, word) |
| ship_strategy : REBALANCE |
| |
