You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@flink.apache.org by pn...@apache.org on 2020/03/25 14:07:16 UTC
[flink] 11/11: [FLINK-16316][operators] Make StreamOperatorFactory
Experimental
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 <pi...@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);
}