This is an automated email from the ASF dual-hosted git repository. lzljs3620320 pushed a commit to branch master in repository https://gitbox.apache.org/repos/asf/flink.git
commit 8614ece9bf73c31a2ef3543822482c33cd7f1ca6 Author: JingsongLi <[email protected]> AuthorDate: Fri Dec 17 15:54:24 2021 +0800 [FLINK-25174][table-api] Introduce Catalog.supportsManagedTable --- flink-python/pyflink/table/tests/test_catalog_completeness.py | 3 ++- .../org/apache/flink/table/catalog/GenericInMemoryCatalog.java | 5 +++++ .../src/main/java/org/apache/flink/table/catalog/Catalog.java | 9 +++++++++ 3 files changed, 16 insertions(+), 1 deletion(-) diff --git a/flink-python/pyflink/table/tests/test_catalog_completeness.py b/flink-python/pyflink/table/tests/test_catalog_completeness.py index b1ba8cb..fd83e29 100644 --- a/flink-python/pyflink/table/tests/test_catalog_completeness.py +++ b/flink-python/pyflink/table/tests/test_catalog_completeness.py @@ -44,7 +44,8 @@ class CatalogAPICompletenessTests(PythonAPICompletenessTestCase, PyFlinkTestCase 'getFactory', 'getTableFactory', 'getFunctionDefinitionFactory', - 'listPartitionsByFilter'} + 'listPartitionsByFilter', + 'supportsManagedTable'} class CatalogDatabaseAPICompletenessTests(PythonAPICompletenessTestCase, PyFlinkTestCase): diff --git a/flink-table/flink-table-api-java/src/main/java/org/apache/flink/table/catalog/GenericInMemoryCatalog.java b/flink-table/flink-table-api-java/src/main/java/org/apache/flink/table/catalog/GenericInMemoryCatalog.java index 9de620f..2e0bed0 100644 --- a/flink-table/flink-table-api-java/src/main/java/org/apache/flink/table/catalog/GenericInMemoryCatalog.java +++ b/flink-table/flink-table-api-java/src/main/java/org/apache/flink/table/catalog/GenericInMemoryCatalog.java @@ -253,6 +253,11 @@ public class GenericInMemoryCatalog extends AbstractCatalog { } } + @Override + public boolean supportsManagedTable() { + return true; + } + // ------ tables and views ------ @Override diff --git a/flink-table/flink-table-common/src/main/java/org/apache/flink/table/catalog/Catalog.java b/flink-table/flink-table-common/src/main/java/org/apache/flink/table/catalog/Catalog.java index e0e4d3e..95cb0f9 100644 --- a/flink-table/flink-table-common/src/main/java/org/apache/flink/table/catalog/Catalog.java +++ b/flink-table/flink-table-common/src/main/java/org/apache/flink/table/catalog/Catalog.java @@ -311,6 +311,15 @@ public interface Catalog { void alterTable(ObjectPath tablePath, CatalogBaseTable newTable, boolean ignoreIfNotExists) throws TableNotExistException, CatalogException; + /** + * If true, tables which do not specify a connector will be translated to managed tables. + * + * @see CatalogBaseTable.TableKind#MANAGED + */ + default boolean supportsManagedTable() { + return false; + } + // ------ partitions ------ /**
