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 2c830898640 [FLINK-36568][rest] Fix incorrect http url for
ClientCoordinationHeaders.
add 2d17f614879 [FLINK-35016][table] Add model to catalog interfaces
No new revisions were added by this update.
Summary of changes:
.../hive/HiveCatalogGenericMetadataTest.java | 5 +
.../catalog/hive/HiveCatalogHiveMetadataTest.java | 5 +
flink-python/pyflink/table/catalog.py | 161 +++++++++++-
flink-python/pyflink/table/tests/test_catalog.py | 151 ++++++++++-
flink-python/pyflink/util/exceptions.py | 16 ++
.../apache/flink/table/catalog/CatalogManager.java | 290 ++++++++++++++++++++-
.../flink/table/catalog/ContextResolvedModel.java | 126 +++++++++
.../table/catalog/GenericInMemoryCatalog.java | 117 ++++++++-
.../table/catalog/listener/AlterModelEvent.java | 69 +++++
.../table/catalog/listener/CreateModelEvent.java | 69 +++++
.../table/catalog/listener/DropModelEvent.java | 72 +++++
.../flink/table/catalog/CatalogManagerTest.java | 165 ++++++++++++
.../flink/table/catalog/CatalogTestBase.java | 21 ++
.../table/catalog/GenericInMemoryCatalogTest.java | 5 +
.../org/apache/flink/table/catalog/Catalog.java | 121 +++++++++
.../apache/flink/table/catalog/CatalogModel.java | 84 ++++++
.../flink/table/catalog/CatalogPropertiesUtil.java | 85 +++++-
.../flink/table/catalog/DefaultCatalogModel.java | 115 ++++++++
.../table/catalog/DefaultResolvedCatalogModel.java | 140 ++++++++++
.../flink/table/catalog/ResolvedCatalogModel.java | 77 ++++++
.../table/catalog/TemporaryOperationListener.java | 21 ++
.../exceptions/ModelAlreadyExistException.java | 37 +++
.../catalog/exceptions/ModelNotExistException.java | 47 ++++
.../table/catalog/CatalogPropertiesUtilTest.java | 124 +++++++++
.../apache/flink/table/catalog/CatalogTest.java | 239 +++++++++++++++++
.../flink/table/api/TableEnvironmentTest.scala | 11 +
26 files changed, 2355 insertions(+), 18 deletions(-)
create mode 100644
flink-table/flink-table-api-java/src/main/java/org/apache/flink/table/catalog/ContextResolvedModel.java
create mode 100644
flink-table/flink-table-api-java/src/main/java/org/apache/flink/table/catalog/listener/AlterModelEvent.java
create mode 100644
flink-table/flink-table-api-java/src/main/java/org/apache/flink/table/catalog/listener/CreateModelEvent.java
create mode 100644
flink-table/flink-table-api-java/src/main/java/org/apache/flink/table/catalog/listener/DropModelEvent.java
create mode 100644
flink-table/flink-table-common/src/main/java/org/apache/flink/table/catalog/CatalogModel.java
create mode 100644
flink-table/flink-table-common/src/main/java/org/apache/flink/table/catalog/DefaultCatalogModel.java
create mode 100644
flink-table/flink-table-common/src/main/java/org/apache/flink/table/catalog/DefaultResolvedCatalogModel.java
create mode 100644
flink-table/flink-table-common/src/main/java/org/apache/flink/table/catalog/ResolvedCatalogModel.java
create mode 100644
flink-table/flink-table-common/src/main/java/org/apache/flink/table/catalog/exceptions/ModelAlreadyExistException.java
create mode 100644
flink-table/flink-table-common/src/main/java/org/apache/flink/table/catalog/exceptions/ModelNotExistException.java
create mode 100644
flink-table/flink-table-common/src/test/java/org/apache/flink/table/catalog/CatalogPropertiesUtilTest.java
