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:03 UTC
[flink] 01/04: [FLINK-25175][table-api] Introduce TableDescriptor.forConnector
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 10805afabe974ccc79aaa1746b31b8c10e3ec65b
Author: JingsongLi <lz...@aliyun.com>
AuthorDate: Fri Dec 17 15:53:24 2021 +0800
[FLINK-25175][table-api] Introduce TableDescriptor.forConnector
---
.../src/main/java/org/apache/flink/table/api/TableDescriptor.java | 5 +++++
1 file changed, 5 insertions(+)
diff --git a/flink-table/flink-table-api-java/src/main/java/org/apache/flink/table/api/TableDescriptor.java b/flink-table/flink-table-api-java/src/main/java/org/apache/flink/table/api/TableDescriptor.java
index 00a4183..afb274d 100644
--- a/flink-table/flink-table-api-java/src/main/java/org/apache/flink/table/api/TableDescriptor.java
+++ b/flink-table/flink-table-api-java/src/main/java/org/apache/flink/table/api/TableDescriptor.java
@@ -81,6 +81,11 @@ public class TableDescriptor {
return descriptorBuilder;
}
+ /** Creates a new {@link Builder} for a managed table. */
+ public static Builder forManaged() {
+ return new Builder();
+ }
+
// ---------------------------------------------------------------------------------------------
public Optional<Schema> getSchema() {