Versions Compared

Key

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

...

Code Block
languagejava
titleNew methods method in TableEnvironment
interface TableEnvironment {
     /**
      * Synchronously execute the given single statement immediately and 
      * the statement can be DDL/DML/SHOW/DESCRIBE/EXPLAIN/USE. 
      * If the statement is translated to a Flink job, the result will be 
      * returned until the job is finished.
      * 
      * @return result for SHOW/DESCRIBE/EXPLAIN, the affected row count 
      * for `DML` (-1 means unknown), or a string message ("OK") for other  
      * statements.
      * @throws Exception which occurs during the execution.
      */
	TableResult executeSql(String statement) throw Exception;
}

...

Code Block
languagejava
titleNew methods method in TableEnvironment
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();
}

...

Code Block
languagejava
titleNew methods method in TableEnvironment
interface TableEnvironment {
   /** 
    * returns the AST and the execution plan to compute the result of 
    * the given statement. 
    * The statement must be DQL or DML, and only single statement is 
    * supported.
    * 
    * @param extraDetails the extra details which the plan should contain. 
    * e.g. estimated cost, uid
    */
    String explainSql(String statement, ExplainDetail... extraDetails);
}

...