提交 ca11c1cc 编写于 作者: T Till Rohrmann

[hotfix] Annotate StoppableFunction as PublicEvolving

上级 90532549
......@@ -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
......
Markdown is supported
0% .
You are about to add 0 people to the discussion. Proceed with caution.
先完成此消息的编辑!
想要评论请 注册