[jira] [Created] (FLINK-16367) Introduce createDmlBatch method in TableEnvironment

["godfrey he (Jira)" <ji...@apache.org>]

godfrey he created FLINK-16367:
----------------------------------

             Summary: Introduce createDmlBatch method in TableEnvironment 
                 Key: FLINK-16367
                 URL: https://issues.apache.org/jira/browse/FLINK-16367
             Project: Flink
          Issue Type: Sub-task
          Components: Table SQL / API
            Reporter: godfrey he
             Fix For: 1.11.0


As we deprecates {{execute}} method and {{explain}} method because of buffering SQLs/Tables execution problem. This issue aims to introduce a new method named createDmlBatch to support executing and explaining the batching queries.

The method likes like:

{code:java}
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.
  */
  DmlBatch createDmlBatch();
}

interface DmlBatch {

  /** 
    * add insert statement to the batch.
    */
   void addInsert(String insert);

  /** 
   * add Table with the given sink table name to the batch. 
   */
   void addInsert(String targetPath, Table table);

  /** 
   * execute all statements and Tables as a batch.
   * 
   * The added statements and Tables will be cleared when  this method. 
   */
   ResultTable execute() throws Exception;
  
   /** 
    * returns the AST and the execution plan to compute the result of the all statements and Tables.
    * 
    * @param extended if the plan should contain additional properties. e.g. estimated cost, traits
    */
    String explain(boolean extended);

}
{code}






--
This message was sent by Atlassian Jira
(v8.3.4#803005)