[FLINK-25174][table-api] Introduce Catalog.supportsManagedTable

jonchase · Dec 17, 2021 · 8614ece · 8614ece
1 parent 10805af
commit 8614ece
Show file tree

Hide file tree

Showing 3 changed files with 16 additions and 1 deletion.
diff --git a/flink-python/pyflink/table/tests/test_catalog_completeness.py b/flink-python/pyflink/table/tests/test_catalog_completeness.py
@@ -44,7 +44,8 @@ def excluded_methods(cls):
             'getFactory',
             'getTableFactory',
             'getFunctionDefinitionFactory',
-            'listPartitionsByFilter'}
+            'listPartitionsByFilter',
+            'supportsManagedTable'}
 
 
 class CatalogDatabaseAPICompletenessTests(PythonAPICompletenessTestCase, PyFlinkTestCase):

diff --git a/...k-table-api-java/src/main/java/org/apache/flink/table/catalog/GenericInMemoryCatalog.java b/...k-table-api-java/src/main/java/org/apache/flink/table/catalog/GenericInMemoryCatalog.java
@@ -253,6 +253,11 @@ public void alterTable(
         }
     }
 
+    @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
@@ -311,6 +311,15 @@ void createTable(ObjectPath tablePath, CatalogBaseTable table, boolean ignoreIfE
     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 ------
 
     /**