This is an automated email from the ASF dual-hosted git repository.
kurt pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/flink.git.
from 0650e4b [FLINK-15669] [sql-client] Fix SQL client can't cancel flink
job
add 3ce6c09 [FLINK-17106][sql-parser] Support to parse TEMPORARY and IF
NOT EXISTS in view definition
add 322d589 [FLINK-17106][table-planner] Support create and drop view in
both planners
No new revisions were added by this update.
Summary of changes:
.../src/main/codegen/data/Parser.tdd | 11 +-
.../src/main/codegen/includes/parserImpls.ftl | 86 ++++-
.../apache/flink/sql/parser/ddl/SqlCreateView.java | 25 +-
.../apache/flink/sql/parser/ddl/SqlDropView.java | 15 +-
.../flink/sql/parser/FlinkSqlParserImplTest.java | 50 +++
.../table/api/internal/TableEnvironmentImpl.java | 37 +-
.../apache/flink/table/catalog/CatalogManager.java | 2 +-
...tionOperation.java => CreateViewOperation.java} | 46 ++-
...nctionOperation.java => DropViewOperation.java} | 34 +-
.../operations/SqlToOperationConverter.java | 67 ++++
.../flink/table/api/TableEnvironmentTest.scala | 376 ++++++++++++++++++-
.../table/planner/catalog/CatalogTableITCase.scala | 2 -
.../table/planner/catalog/CatalogViewITCase.scala | 333 +++++++++++++++++
.../table/sqlexec/SqlToOperationConverter.java | 80 ++++
.../flink/table/api/internal/TableEnvImpl.scala | 28 ++
.../flink/table/calcite/FlinkPlannerImpl.scala | 2 +-
.../flink/table/catalog/CatalogManagerTest.java | 2 +-
.../flink/table/catalog/CatalogTableITCase.scala | 403 +++++++++++++++++++++
18 files changed, 1516 insertions(+), 83 deletions(-)
copy
flink-table/flink-table-api-java/src/main/java/org/apache/flink/table/operations/ddl/{CreateCatalogFunctionOperation.java
=> CreateViewOperation.java} (62%)
copy
flink-table/flink-table-api-java/src/main/java/org/apache/flink/table/operations/ddl/{DropCatalogFunctionOperation.java
=> DropViewOperation.java} (72%)
create mode 100644
flink-table/flink-table-planner-blink/src/test/scala/org/apache/flink/table/planner/catalog/CatalogViewITCase.scala
