You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@flink.apache.org by tr...@apache.org on 2016/02/15 16:45:52 UTC
flink git commit: [hotfix] Annotate StoppableFunction as
PublicEvolving
Repository: flink
Updated Branches:
refs/heads/master 90532549e -> ca11c1ccc
[hotfix] Annotate StoppableFunction as PublicEvolving
Project: http://git-wip-us.apache.org/repos/asf/flink/repo
Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/ca11c1cc
Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/ca11c1cc
Diff: http://git-wip-us.apache.org/repos/asf/flink/diff/ca11c1cc
Branch: refs/heads/master
Commit: ca11c1ccc7e7e0c02a2450dfd71a950b6a484648
Parents: 9053254
Author: Till Rohrmann <tr...@apache.org>
Authored: Mon Feb 15 16:44:59 2016 +0100
Committer: Till Rohrmann <tr...@apache.org>
Committed: Mon Feb 15 16:44:59 2016 +0100
----------------------------------------------------------------------
.../org/apache/flink/api/common/functions/StoppableFunction.java | 3 +++
1 file changed, 3 insertions(+)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/flink/blob/ca11c1cc/flink-core/src/main/java/org/apache/flink/api/common/functions/StoppableFunction.java
----------------------------------------------------------------------
diff --git a/flink-core/src/main/java/org/apache/flink/api/common/functions/StoppableFunction.java b/flink-core/src/main/java/org/apache/flink/api/common/functions/StoppableFunction.java
index 51dd779..e6da8a8 100644
--- a/flink-core/src/main/java/org/apache/flink/api/common/functions/StoppableFunction.java
+++ b/flink-core/src/main/java/org/apache/flink/api/common/functions/StoppableFunction.java
@@ -12,11 +12,14 @@
*/
package org.apache.flink.api.common.functions;
+import org.apache.flink.annotation.PublicEvolving;
+
/**
* Must be implemented by stoppable functions, eg, source functions of streaming jobs. The method {@link #stop()} will
* be called when the job received the STOP signal. On this signal, the source function must stop emitting new data and
* terminate gracefully.
*/
+@PublicEvolving
public interface StoppableFunction {
/**
* Stops the source. In contrast to {@code cancel()} this is a request to the source function to shut down