You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@flink.apache.org by tw...@apache.org on 2019/07/31 11:54:47 UTC
[flink] 06/06: [hotfix][table] Add missing annotations to factories
This is an automated email from the ASF dual-hosted git repository.
twalthr pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/flink.git
commit fa4ee95f07bcb58f1f6d1ca6fa04a37f771e05c0
Author: Timo Walther <tw...@apache.org>
AuthorDate: Tue Jul 30 18:27:02 2019 +0200
[hotfix][table] Add missing annotations to factories
---
.../java/org/apache/flink/table/factories/BatchTableSinkFactory.java | 2 ++
.../java/org/apache/flink/table/factories/BatchTableSourceFactory.java | 2 ++
.../java/org/apache/flink/table/factories/StreamTableSinkFactory.java | 2 ++
.../java/org/apache/flink/table/factories/StreamTableSourceFactory.java | 2 ++
4 files changed, 8 insertions(+)
diff --git a/flink-table/flink-table-api-java-bridge/src/main/java/org/apache/flink/table/factories/BatchTableSinkFactory.java b/flink-table/flink-table-api-java-bridge/src/main/java/org/apache/flink/table/factories/BatchTableSinkFactory.java
index 910dc82..13dcc71 100644
--- a/flink-table/flink-table-api-java-bridge/src/main/java/org/apache/flink/table/factories/BatchTableSinkFactory.java
+++ b/flink-table/flink-table-api-java-bridge/src/main/java/org/apache/flink/table/factories/BatchTableSinkFactory.java
@@ -18,6 +18,7 @@
package org.apache.flink.table.factories;
+import org.apache.flink.annotation.PublicEvolving;
import org.apache.flink.table.sinks.BatchTableSink;
import org.apache.flink.table.sinks.TableSink;
@@ -29,6 +30,7 @@ import java.util.Map;
*
* @param <T> type of records that the factory consumes
*/
+@PublicEvolving
public interface BatchTableSinkFactory<T> extends TableSinkFactory<T> {
/**
diff --git a/flink-table/flink-table-api-java-bridge/src/main/java/org/apache/flink/table/factories/BatchTableSourceFactory.java b/flink-table/flink-table-api-java-bridge/src/main/java/org/apache/flink/table/factories/BatchTableSourceFactory.java
index 05db20b..267385d 100644
--- a/flink-table/flink-table-api-java-bridge/src/main/java/org/apache/flink/table/factories/BatchTableSourceFactory.java
+++ b/flink-table/flink-table-api-java-bridge/src/main/java/org/apache/flink/table/factories/BatchTableSourceFactory.java
@@ -18,6 +18,7 @@
package org.apache.flink.table.factories;
+import org.apache.flink.annotation.PublicEvolving;
import org.apache.flink.table.sources.BatchTableSource;
import org.apache.flink.table.sources.TableSource;
@@ -29,6 +30,7 @@ import java.util.Map;
*
* @param <T> type of records that the factory produces
*/
+@PublicEvolving
public interface BatchTableSourceFactory<T> extends TableSourceFactory<T> {
/**
diff --git a/flink-table/flink-table-api-java-bridge/src/main/java/org/apache/flink/table/factories/StreamTableSinkFactory.java b/flink-table/flink-table-api-java-bridge/src/main/java/org/apache/flink/table/factories/StreamTableSinkFactory.java
index be25844..86c7e82 100644
--- a/flink-table/flink-table-api-java-bridge/src/main/java/org/apache/flink/table/factories/StreamTableSinkFactory.java
+++ b/flink-table/flink-table-api-java-bridge/src/main/java/org/apache/flink/table/factories/StreamTableSinkFactory.java
@@ -18,6 +18,7 @@
package org.apache.flink.table.factories;
+import org.apache.flink.annotation.PublicEvolving;
import org.apache.flink.table.sinks.StreamTableSink;
import org.apache.flink.table.sinks.TableSink;
@@ -29,6 +30,7 @@ import java.util.Map;
*
* @param <T> type of records that the factory consumes
*/
+@PublicEvolving
public interface StreamTableSinkFactory<T> extends TableSinkFactory<T> {
/**
diff --git a/flink-table/flink-table-api-java-bridge/src/main/java/org/apache/flink/table/factories/StreamTableSourceFactory.java b/flink-table/flink-table-api-java-bridge/src/main/java/org/apache/flink/table/factories/StreamTableSourceFactory.java
index 26b5e9c..b007d7b 100644
--- a/flink-table/flink-table-api-java-bridge/src/main/java/org/apache/flink/table/factories/StreamTableSourceFactory.java
+++ b/flink-table/flink-table-api-java-bridge/src/main/java/org/apache/flink/table/factories/StreamTableSourceFactory.java
@@ -18,6 +18,7 @@
package org.apache.flink.table.factories;
+import org.apache.flink.annotation.PublicEvolving;
import org.apache.flink.table.sources.StreamTableSource;
import org.apache.flink.table.sources.TableSource;
@@ -29,6 +30,7 @@ import java.util.Map;
*
* @param <T> type of records that the factory produces
*/
+@PublicEvolving
public interface StreamTableSourceFactory<T> extends TableSourceFactory<T> {
/**