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 <[email protected]> Authored: Mon Feb 15 16:44:59 2016 +0100 Committer: Till Rohrmann <[email protected]> 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
