This is an automated email from the ASF dual-hosted git repository.
leonard pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/flink.git
from 48d4d5ccd8d [FLINK-31643][network] Restrict the max number of required
buffers per input gate in tiered storage
add f8812dc3bc8 [FLINK-32433][table] Add built-in FileCatalogStore
implementation
add 65214293470 [FLINK-32431][table] Support configuring CatalogStore in
Table API
add e3154d3e4c8 [FLINK-32429][table] Introduce CatalogStore in
CatalogManager
add c8dfb2a1c68 [FLINK-32430][table] Support configuring CatalogStore
using configuration
No new revisions were added by this update.
Summary of changes:
.../table/tests/test_environment_completeness.py | 4 +-
.../test_environment_settings_completeness.py | 4 +-
flink-table/flink-sql-gateway/pom.xml | 7 +
.../gateway/service/context/SessionContext.java | 20 +-
.../service/session/SessionManagerImplTest.java | 108 +++++++++
.../java/internal/StreamTableEnvironmentImpl.java | 22 ++
.../flink/table/api/EnvironmentSettings.java | 26 ++-
.../apache/flink/table/api/TableEnvironment.java | 16 ++
.../table/api/internal/TableEnvironmentImpl.java | 28 +++
.../apache/flink/table/catalog/CatalogManager.java | 171 ++++++++++++--
.../flink/table/catalog/FileCatalogStore.java | 248 +++++++++++++++++++++
.../table/catalog/FileCatalogStoreFactory.java | 51 +++--
.../catalog/FileCatalogStoreFactoryOptions.java} | 25 +--
.../GenericInMemoryCatalogStoreFactory.java | 2 +-
.../flink/table/factories/TableFactoryUtil.java | 50 +++++
.../operations/ddl/CreateCatalogOperation.java | 14 +-
.../org.apache.flink.table.factories.Factory | 1 +
.../flink/table/catalog/CatalogManagerTest.java | 75 +++++++
.../flink/table/catalog/FileCatalogStoreTest.java | 149 +++++++++++++
.../GenericInMemoryCatalogStoreFactoryTest.java | 2 +-
.../flink/table/utils/CatalogManagerMocks.java | 33 ++-
.../internal/StreamTableEnvironmentImpl.scala | 18 ++
.../flink/table/catalog/CatalogStoreHolder.java | 131 +++++++++++
.../flink/table/catalog/CommonCatalogOptions.java | 10 +
.../flink/table/factories/CatalogStoreFactory.java | 2 +-
.../apache/flink/table/factories/FactoryUtil.java | 23 ++
.../flink/table/factories/FactoryUtilTest.java | 2 +-
.../table/factories/TestCatalogStoreFactory.java | 47 ++--
.../apache/flink/table/api/EnvironmentTest.java | 19 ++
.../flink/table/planner/utils/TableTestBase.scala | 9 +-
30 files changed, 1222 insertions(+), 95 deletions(-)
create mode 100644
flink-table/flink-table-api-java/src/main/java/org/apache/flink/table/catalog/FileCatalogStore.java
copy
flink-python/src/main/java/org/apache/flink/table/utils/python/PythonDynamicTableFactory.java
=>
flink-table/flink-table-api-java/src/main/java/org/apache/flink/table/catalog/FileCatalogStoreFactory.java
(52%)
copy
flink-table/{flink-table-runtime/src/main/java/org/apache/flink/formats/raw/RawFormatOptions.java
=>
flink-table-api-java/src/main/java/org/apache/flink/table/catalog/FileCatalogStoreFactoryOptions.java}
(64%)
create mode 100644
flink-table/flink-table-api-java/src/test/java/org/apache/flink/table/catalog/FileCatalogStoreTest.java
create mode 100644
flink-table/flink-table-common/src/main/java/org/apache/flink/table/catalog/CatalogStoreHolder.java
