This is an automated email from the ASF dual-hosted git repository.
renqs pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/flink.git
from 410b52a35a1 [FLINK-32474][table] Support time travel in table planner
(#22939)
add 151566d21e7 [FLINK-32406][table] Notify catalog modification listener
for database ddl in CatalogManager (#23039)
No new revisions were added by this update.
Summary of changes:
.../apache/flink/table/catalog/CatalogManager.java | 28 +++++
.../table/catalog/listener/AlterDatabaseEvent.java | 70 +++++++++++
.../table/catalog/listener/CatalogContext.java | 36 +++++-
.../catalog/listener/CreateDatabaseEvent.java} | 44 ++++---
...onEvent.java => DatabaseModificationEvent.java} | 15 ++-
.../table/catalog/listener/DropDatabaseEvent.java | 65 ++++++++++
.../flink/table/catalog/CatalogManagerTest.java | 137 +++++++++++++++++++++
7 files changed, 369 insertions(+), 26 deletions(-)
create mode 100644
flink-table/flink-table-api-java/src/main/java/org/apache/flink/table/catalog/listener/AlterDatabaseEvent.java
copy
flink-table/{flink-table-common/src/main/java/org/apache/flink/table/connector/source/lookup/PartialCachingLookupProvider.java
=>
flink-table-api-java/src/main/java/org/apache/flink/table/catalog/listener/CreateDatabaseEvent.java}
(50%)
copy
flink-table/flink-table-api-java/src/main/java/org/apache/flink/table/catalog/listener/{CatalogModificationEvent.java
=> DatabaseModificationEvent.java} (71%)
create mode 100644
flink-table/flink-table-api-java/src/main/java/org/apache/flink/table/catalog/listener/DropDatabaseEvent.java
create mode 100644
flink-table/flink-table-api-java/src/test/java/org/apache/flink/table/catalog/CatalogManagerTest.java
