You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@flink.apache.org by tw...@apache.org on 2022/01/14 08:23:47 UTC
[flink] branch master updated (ac32c9f -> 6def8d7)
This is an automated email from the ASF dual-hosted git repository.
twalthr pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/flink.git.
from ac32c9f [FLINK-25230][table-planner] Regenerate JSON plans
add 6def8d7 [FLINK-25392][table-planner] Support new EXECUTE STATEMENT SET BEGIN ... END; syntax
No new revisions were added by this update.
Summary of changes:
.../src/main/codegen/data/Parser.tdd | 3 +
.../src/main/codegen/includes/parserImpls.ftl | 49 ++++++++++
.../SqlRichExplain.java => dml/SqlExecute.java} | 50 +++++-----
.../SqlStatementSet.java} | 67 ++++++-------
.../flink/sql/parser/FlinkSqlParserImplTest.java | 45 +++++++++
.../table/api/internal/TableEnvironmentImpl.java | 19 +++-
.../operations/BeginStatementSetOperation.java | 5 +-
.../table/operations/EndStatementSetOperation.java | 5 +-
.../flink/table/operations/ExplainOperation.java | 5 +-
.../table/operations/StatementSetOperation.java | 31 +++++-
.../planner/calcite/FlinkCalciteSqlValidator.java | 14 ---
.../operations/SqlToOperationConverter.java | 38 ++++++--
.../table/planner/calcite/FlinkPlannerImpl.scala | 37 ++++---
.../calcite/FlinkCalciteSqlValidatorTest.java | 19 +++-
.../operations/SqlToOperationConverterTest.java | 90 +++++++++++++++++
.../explain/testStatementSetExecutionExplain.out | 71 ++++++++++++++
.../flink/table/api/TableEnvironmentITCase.scala | 46 ++++++++-
.../flink/table/api/TableEnvironmentTest.scala | 107 ++++++++++++++++-----
18 files changed, 567 insertions(+), 134 deletions(-)
copy flink-table/flink-sql-parser/src/main/java/org/apache/flink/sql/parser/{dql/SqlRichExplain.java => dml/SqlExecute.java} (64%)
copy flink-table/flink-sql-parser/src/main/java/org/apache/flink/sql/parser/{dql/SqlRichExplain.java => dml/SqlStatementSet.java} (54%)