You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@flink.apache.org by lz...@apache.org on 2021/12/17 08:03:04 UTC
[flink] 02/04: [FLINK-25174][table-api] Introduce Catalog.supportsManagedTable
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 <lz...@aliyun.com>
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 ------
/**