You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@flink.apache.org by dw...@apache.org on 2019/12/19 21:44:32 UTC
[flink] 09/11: [hotfix][table-common] Deprecate
TableSource#getSchema.
This is an automated email from the ASF dual-hosted git repository.
dwysakowicz pushed a commit to branch release-1.10
in repository https://gitbox.apache.org/repos/asf/flink.git
commit 4e3fb3c78e76cd13dadda58c36ff18fb037b5269
Author: Dawid Wysakowicz <dw...@apache.org>
AuthorDate: Fri Dec 13 09:50:06 2019 +0100
[hotfix][table-common] Deprecate TableSource#getSchema.
---
.../src/main/java/org/apache/flink/table/sources/TableSource.java | 3 +++
1 file changed, 3 insertions(+)
diff --git a/flink-table/flink-table-common/src/main/java/org/apache/flink/table/sources/TableSource.java b/flink-table/flink-table-common/src/main/java/org/apache/flink/table/sources/TableSource.java
index 386240b..1567be1 100644
--- a/flink-table/flink-table-common/src/main/java/org/apache/flink/table/sources/TableSource.java
+++ b/flink-table/flink-table-common/src/main/java/org/apache/flink/table/sources/TableSource.java
@@ -73,7 +73,10 @@ public interface TableSource<T> {
* Returns the schema of the produced table.
*
* @return The {@link TableSchema} of the produced table.
+ * @deprecated Table schema is a logical description of a table and should not be part of the physical TableSource.
+ * Define schema when registering a Table either in DDL or in {@code TableEnvironment#connect(...)}.
*/
+ @Deprecated
TableSchema getTableSchema();
/**