This is an automated email from the ASF dual-hosted git repository. twalthr pushed a commit to branch release-1.9 in repository https://gitbox.apache.org/repos/asf/flink.git
commit 48bc4b140102129d2c201fe5a309e1c8e73edc78 Author: Timo Walther <twal...@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> { /**