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 384e7f0 [hotfix][datastream] bug fix
add faed56f [hotfix][sql-parser] Convert tests to JUnit 5 and enable
parallel test execution
add 38f0592 [FLINK-25845][table] Add EXECUTE PLAN
add 1923d70 [FLINK-25845][table] Add COMPILE PLAN and COMPILE AND EXECUTE
PLAN
add 08955e0 [hotfix][docs] Improve guide for generating config options
docs
No new revisions were added by this update.
Summary of changes:
docs/README.md | 4 +-
.../generated/table_config_configuration.html | 6 +
.../src/main/codegen/data/Parser.tdd | 10 +-
.../src/main/codegen/includes/parserImpls.ftl | 78 ++++-
.../flink/sql/parser/ddl/SqlCompilePlan.java | 113 +++++++
...lExecute.java => SqlCompileAndExecutePlan.java} | 60 ++--
...lBeginStatementSet.java => SqlExecutePlan.java} | 28 +-
.../junit-platform.properties | 0
.../flink/sql/parser/FlinkSqlParserImplTest.java | 102 ++++++-
.../flink/sql/parser/FlinkSqlUnParserTest.java | 5 +
.../org/apache/flink/table/api/CompiledPlan.java | 23 +-
.../apache/flink/table/api/TableEnvironment.java | 10 +-
.../flink/table/api/config/TableConfigOptions.java | 11 +
.../table/api/internal/TableEnvironmentImpl.java | 69 ++++-
...on.java => CompileAndExecutePlanOperation.java} | 45 ++-
...JarOperation.java => ExecutePlanOperation.java} | 18 +-
.../table/operations/ddl/CompilePlanOperation.java | 61 ++++
.../operations/SqlToOperationConverter.java | 54 +++-
.../planner/plan/ExecNodeGraphCompiledPlan.java | 37 ++-
.../table/planner/calcite/FlinkPlannerImpl.scala | 16 +-
.../apache/flink/table/api/CompiledPlanITCase.java | 332 +++++++++++++++++++++
.../api/internal/TableEnvironmentInternalTest.java | 134 ---------
.../table/planner/utils/JsonPlanTestBase.java | 7 +-
23 files changed, 964 insertions(+), 259 deletions(-)
create mode 100644
flink-table/flink-sql-parser/src/main/java/org/apache/flink/sql/parser/ddl/SqlCompilePlan.java
copy
flink-table/flink-sql-parser/src/main/java/org/apache/flink/sql/parser/dml/{SqlExecute.java
=> SqlCompileAndExecutePlan.java} (54%)
copy
flink-table/flink-sql-parser/src/main/java/org/apache/flink/sql/parser/dml/{SqlBeginStatementSet.java
=> SqlExecutePlan.java} (68%)
copy flink-table/{flink-table-planner/src/test/resources =>
flink-sql-parser/src/main/resources/org.apache.flink.sql.parser.utils}/junit-platform.properties
(100%)
copy
flink-table/flink-table-api-java/src/main/java/org/apache/flink/table/operations/{StatementSetOperation.java
=> CompileAndExecutePlanOperation.java} (54%)
copy
flink-table/flink-table-api-java/src/main/java/org/apache/flink/table/operations/command/{AddJarOperation.java
=> ExecutePlanOperation.java} (70%)
create mode 100644
flink-table/flink-table-api-java/src/main/java/org/apache/flink/table/operations/ddl/CompilePlanOperation.java
create mode 100644
flink-table/flink-table-planner/src/test/java/org/apache/flink/table/api/CompiledPlanITCase.java
delete mode 100644
flink-table/flink-table-planner/src/test/java/org/apache/flink/table/api/internal/TableEnvironmentInternalTest.java