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 2bd9cec [FLINK-15016][build] Remove unused dependency
add 02a8c41 [FLINK-14691][table] Support create/drop/alter/use database
in TableEnvironment
add 6d677fb [hotfix] Fix the comment about dropping database in in-memory
catalog
No new revisions were added by this update.
Summary of changes:
.../flink/table/catalog/hive/HiveCatalog.java | 6 +-
.../hive/client/HiveMetastoreClientWrapper.java | 5 +
.../src/main/codegen/includes/parserImpls.ftl | 8 +-
.../flink/sql/parser/ddl/SqlAlterDatabase.java | 2 +-
.../flink/sql/parser/ddl/SqlCreateDatabase.java | 2 +-
.../flink/sql/parser/ddl/SqlDropDatabase.java | 26 +++---
.../flink/sql/parser/ddl/SqlUseDatabase.java | 3 +-
.../table/api/internal/TableEnvironmentImpl.java | 75 +++++++++++++--
.../table/catalog/GenericInMemoryCatalog.java | 23 ++++-
...logOperation.java => UseDatabaseOperation.java} | 16 +++-
...eOperation.java => AlterDatabaseOperation.java} | 40 +++++---
.../{DropOperation.java => AlterOperation.java} | 8 +-
...Operation.java => CreateDatabaseOperation.java} | 46 +++++----
...leOperation.java => DropDatabaseOperation.java} | 50 +++++-----
.../table/catalog/GenericInMemoryCatalogTest.java | 4 +-
.../org/apache/flink/table/catalog/Catalog.java | 22 ++++-
.../apache/flink/table/catalog/CatalogTest.java | 14 +--
.../operations/SqlToOperationConverter.java | 94 +++++++++++++++++++
.../operations/SqlToOperationConverterTest.java | 103 ++++++++++++++++++++-
.../table/planner/catalog/CatalogTableITCase.scala | 103 ++++++++++++++++++++-
.../table/sqlexec/SqlToOperationConverter.java | 95 +++++++++++++++++++
.../flink/table/api/internal/TableEnvImpl.scala | 72 ++++++++++++--
.../table/sqlexec/SqlToOperationConverterTest.java | 103 ++++++++++++++++++++-
.../flink/table/catalog/CatalogTableITCase.scala | 103 ++++++++++++++++++++-
24 files changed, 893 insertions(+), 130 deletions(-)
copy
flink-table/flink-table-api-java/src/main/java/org/apache/flink/table/operations/{UseCatalogOperation.java
=> UseDatabaseOperation.java} (69%)
copy
flink-table/flink-table-api-java/src/main/java/org/apache/flink/table/operations/ddl/{DropTableOperation.java
=> AlterDatabaseOperation.java} (59%)
copy
flink-table/flink-table-api-java/src/main/java/org/apache/flink/table/operations/ddl/{DropOperation.java
=> AlterOperation.java} (82%)
copy
flink-table/flink-table-api-java/src/main/java/org/apache/flink/table/operations/ddl/{CreateTableOperation.java
=> CreateDatabaseOperation.java} (61%)
copy
flink-table/flink-table-api-java/src/main/java/org/apache/flink/table/operations/ddl/{DropTableOperation.java
=> DropDatabaseOperation.java} (53%)
