[FLINK-16367] Introduce createStatementSet method in TableEnvironment

• Type: Sub-task
• Status: Closed
• Priority: Major
• Resolution: Fixed
• Fix Version/s: 1.11.0
• Component/s: Table SQL / API
• Labels: pull-request-available
• Assignee: godfrey he
• Reporter: godfrey he
• Created: 02/Mar/20 08:06
• Updated: 30/Apr/21 09:51
• Resolved: 10/May/20 11:50

Description

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

interface TableEnvironment {

 /**
    * Create a StatementSet instance which can add DML statements or Tables
    * to the set, the planner can optimize all added statements and Tables
    * together for better performance.
    */
    StatementSet createStatementSet();
}

interface StatementSet  {
    /**
     * add insert statement to the set.
     */
    StatementSet addInsertSql(String statement);
 
    /**
     * add Table with the given sink table name to the set.
     */
    StatementSet addInsert(String targetPath, Table table);
 
    /**
     * add Table with the given sink table name to the set.
     */
    StatementSet addInsert(String targetPath, Table table, boolean overwrite);
 
    /**
     * returns the AST and the execution plan to compute the result of the
     * all statements and Tables.
     *
     * @param extraDetails the extra details which the plan should contain.
     * e.g. estimated cost, uid
     */
    String explain(ExplainDetail... extraDetails);
 
    /**
     * execute all statements and Tables as a batch.
     *
     * The added statements and Tables will be cleared when executing
     * this method.
     */
    TableResult execute();
}

Issue Links

• causes: FLINK-17601 TableEnvironmentITCase.testStatementSet fails on travis
• is blocked by: FLINK-17126 Correct the execution behavior of BatchTableEnvironment
• relates to: FLINK-14098 Support multiple statements for TableEnvironment
• links to: GitHub Pull Request #12042