This is an automated email from the ASF dual-hosted git repository.

pnowojski pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/flink.git

commit 73d410354d367e91ec6f68af87115cee0d86a0ac
Author: Piotr Nowojski <piotr.nowoj...@gmail.com>
AuthorDate: Fri Mar 13 12:21:08 2020 +0100

    [FLINK-16316][operators] Make StreamOperatorFactory Experimental
---
 .../flink/streaming/api/operators/AbstractStreamOperatorFactory.java  | 2 ++
 .../apache/flink/streaming/api/operators/StreamOperatorFactory.java   | 4 ++--
 .../apache/flink/streaming/api/operators/YieldingOperatorFactory.java | 3 +++
 3 files changed, 7 insertions(+), 2 deletions(-)

diff --git 
a/flink-streaming-java/src/main/java/org/apache/flink/streaming/api/operators/AbstractStreamOperatorFactory.java
 
b/flink-streaming-java/src/main/java/org/apache/flink/streaming/api/operators/AbstractStreamOperatorFactory.java
index f29c860..23fa40d 100644
--- 
a/flink-streaming-java/src/main/java/org/apache/flink/streaming/api/operators/AbstractStreamOperatorFactory.java
+++ 
b/flink-streaming-java/src/main/java/org/apache/flink/streaming/api/operators/AbstractStreamOperatorFactory.java
@@ -17,6 +17,7 @@
 
 package org.apache.flink.streaming.api.operators;
 
+import org.apache.flink.annotation.Experimental;
 import org.apache.flink.streaming.runtime.tasks.ProcessingTimeService;
 import org.apache.flink.streaming.runtime.tasks.ProcessingTimeServiceAware;
 
@@ -25,6 +26,7 @@ import 
org.apache.flink.streaming.runtime.tasks.ProcessingTimeServiceAware;
  * {@link ProcessingTimeServiceAware} interface which enables stream operators 
to access
  * {@link ProcessingTimeService}.
  */
+@Experimental
 public abstract class AbstractStreamOperatorFactory<OUT> implements 
StreamOperatorFactory<OUT>, ProcessingTimeServiceAware {
 
        protected ChainingStrategy chainingStrategy = ChainingStrategy.ALWAYS;
diff --git 
a/flink-streaming-java/src/main/java/org/apache/flink/streaming/api/operators/StreamOperatorFactory.java
 
b/flink-streaming-java/src/main/java/org/apache/flink/streaming/api/operators/StreamOperatorFactory.java
index 19df001..d1ea80c 100644
--- 
a/flink-streaming-java/src/main/java/org/apache/flink/streaming/api/operators/StreamOperatorFactory.java
+++ 
b/flink-streaming-java/src/main/java/org/apache/flink/streaming/api/operators/StreamOperatorFactory.java
@@ -17,7 +17,7 @@
 
 package org.apache.flink.streaming.api.operators;
 
-import org.apache.flink.annotation.Internal;
+import org.apache.flink.annotation.Experimental;
 import org.apache.flink.api.common.ExecutionConfig;
 import org.apache.flink.api.common.typeinfo.TypeInformation;
 import org.apache.flink.streaming.api.graph.StreamGraph;
@@ -30,7 +30,7 @@ import java.io.Serializable;
  *
  * @param <OUT> The output type of the operator
  */
-@Internal
+@Experimental
 public interface StreamOperatorFactory<OUT> extends Serializable {
 
        /**
diff --git 
a/flink-streaming-java/src/main/java/org/apache/flink/streaming/api/operators/YieldingOperatorFactory.java
 
b/flink-streaming-java/src/main/java/org/apache/flink/streaming/api/operators/YieldingOperatorFactory.java
index 054ad8d..c3563c5 100644
--- 
a/flink-streaming-java/src/main/java/org/apache/flink/streaming/api/operators/YieldingOperatorFactory.java
+++ 
b/flink-streaming-java/src/main/java/org/apache/flink/streaming/api/operators/YieldingOperatorFactory.java
@@ -17,10 +17,13 @@
 
 package org.apache.flink.streaming.api.operators;
 
+import org.apache.flink.annotation.Experimental;
+
 /**
  * An operator that needs access to the {@link MailboxExecutor} to yield to 
downstream operators needs to be created
  * through a factory implementing this interface.
  */
+@Experimental
 public interface YieldingOperatorFactory<OUT> extends 
StreamOperatorFactory<OUT> {
        void setMailboxExecutor(MailboxExecutor mailboxExecutor);
 }

Reply via email to