Versions Compared

Old Version 11

changes.mady.by.user godfreyhe

Saved on

compared with

New Version 12

changes.mady.by.user godfreyhe

Saved on

Key

  • This line was added.
  • This line was removed.
  • Formatting was changed.

...

interface TableEnvironment {

 /** 
  * Create a DmlBatch instance which can add dml statements or Tables to the batch,
  * the planner can optimize all added statements and Tables together for better performance.
  */
  DmlBatchcreateDmlBatch();

}

...

To meet the requirement, we will change the current behavior of TableEnvironment: TableEnvironment instance buffers the SQLs/Tables and does not add generated transformations to the StreamExecutionEnvironment instance when translating to execution plan. (The solution is similar to DummyStreamExecutionEnvironment. We can use StreamGraphGenerator to generate StreamGraph based on the transformations. This requires the StreamTableSink always returns DataStream, and the StreamTableSink#emitDataStream method should be removed since it’s deprecated in Flink 1.9) StreamExecutionEnvironment instance only buffers the transformation translated from DataStream.

...