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