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 d8e77674a88 [FLINK-32403][table] Add database related operations in
CatalogManager (#22869)
add fd96076b1b4 [FLINK-32404][table] Add catalog modification listener
interface and create listener for catalog manager (#22924)
No new revisions were added by this update.
Summary of changes:
.../generated/table_config_configuration.html | 14 +++--
.../gateway/service/context/SessionContext.java | 6 +-
.../service/context/SessionContextTest.java | 69 +++++++++++++++++++++
.../java/internal/StreamTableEnvironmentImpl.java | 4 ++
.../flink/table/api/config/TableConfigOptions.java | 13 ++++
.../table/api/internal/TableEnvironmentImpl.java | 3 +
.../apache/flink/table/catalog/CatalogManager.java | 25 +++++++-
.../table/catalog/listener/CatalogContext.java | 45 ++++++++++++++
.../catalog/listener/CatalogModificationEvent.java | 31 ++++++++++
.../listener/CatalogModificationListener.java | 34 ++++++++++
.../CatalogModificationListenerFactory.java | 57 +++++++++++++++++
.../flink/table/factories/TableFactoryUtil.java | 32 ++++++++++
.../table/catalog/listener/CatalogFactory1.java | 34 ++++++++++
.../table/catalog/listener/CatalogFactory2.java | 34 ++++++++++
.../table/catalog/listener/CatalogListener1.java | 28 +++++++++
.../table/catalog/listener/CatalogListener2.java | 28 +++++++++
.../listener/CatalogListenerFactoryTest.java | 59 ++++++++++++++++++
.../org.apache.flink.table.factories.Factory | 17 +++++
.../internal/StreamTableEnvironmentImpl.scala | 6 +-
.../apache/flink/table/api/EnvironmentTest.java | 72 ++++++++++++++++++++--
.../runtime/catalog/CatalogListenerTest.scala | 61 ++++++++++++++++++
21 files changed, 659 insertions(+), 13 deletions(-)
create mode 100644
flink-table/flink-table-api-java/src/main/java/org/apache/flink/table/catalog/listener/CatalogContext.java
create mode 100644
flink-table/flink-table-api-java/src/main/java/org/apache/flink/table/catalog/listener/CatalogModificationEvent.java
create mode 100644
flink-table/flink-table-api-java/src/main/java/org/apache/flink/table/catalog/listener/CatalogModificationListener.java
create mode 100644
flink-table/flink-table-api-java/src/main/java/org/apache/flink/table/catalog/listener/CatalogModificationListenerFactory.java
create mode 100644
flink-table/flink-table-api-java/src/test/java/org/apache/flink/table/catalog/listener/CatalogFactory1.java
create mode 100644
flink-table/flink-table-api-java/src/test/java/org/apache/flink/table/catalog/listener/CatalogFactory2.java
create mode 100644
flink-table/flink-table-api-java/src/test/java/org/apache/flink/table/catalog/listener/CatalogListener1.java
create mode 100644
flink-table/flink-table-api-java/src/test/java/org/apache/flink/table/catalog/listener/CatalogListener2.java
create mode 100644
flink-table/flink-table-api-java/src/test/java/org/apache/flink/table/catalog/listener/CatalogListenerFactoryTest.java
create mode 100644
flink-table/flink-table-api-java/src/test/resources/META-INF/services/org.apache.flink.table.factories.Factory
create mode 100644
flink-table/flink-table-planner/src/test/scala/org/apache/flink/table/planner/runtime/catalog/CatalogListenerTest.scala
