This is an automated email from the ASF dual-hosted git repository. sewen pushed a commit to branch release-1.11 in repository https://gitbox.apache.org/repos/asf/flink.git
commit 25cad5fb517bc8a6a6e2a37c78e43c474a99bbd9 Author: Stephan Ewen <[email protected]> AuthorDate: Wed Jun 24 18:07:22 2020 +0200 [FLINK-18430][DataStream API] Classify CheckpointedFunction and CheckpointListener as @Public --- .../main/java/org/apache/flink/runtime/state/CheckpointListener.java | 4 ++-- .../apache/flink/streaming/api/checkpoint/CheckpointedFunction.java | 4 ++-- 2 files changed, 4 insertions(+), 4 deletions(-) diff --git a/flink-runtime/src/main/java/org/apache/flink/runtime/state/CheckpointListener.java b/flink-runtime/src/main/java/org/apache/flink/runtime/state/CheckpointListener.java index adc4baf..a32b597 100644 --- a/flink-runtime/src/main/java/org/apache/flink/runtime/state/CheckpointListener.java +++ b/flink-runtime/src/main/java/org/apache/flink/runtime/state/CheckpointListener.java @@ -18,14 +18,14 @@ package org.apache.flink.runtime.state; -import org.apache.flink.annotation.PublicEvolving; +import org.apache.flink.annotation.Public; /** * This interface must be implemented by functions/operations that want to receive * a commit notification once a checkpoint has been completely acknowledged by all * participants. */ -@PublicEvolving +@Public public interface CheckpointListener { /** diff --git a/flink-streaming-java/src/main/java/org/apache/flink/streaming/api/checkpoint/CheckpointedFunction.java b/flink-streaming-java/src/main/java/org/apache/flink/streaming/api/checkpoint/CheckpointedFunction.java index 604e7f4..5aeeb34 100644 --- a/flink-streaming-java/src/main/java/org/apache/flink/streaming/api/checkpoint/CheckpointedFunction.java +++ b/flink-streaming-java/src/main/java/org/apache/flink/streaming/api/checkpoint/CheckpointedFunction.java @@ -18,7 +18,7 @@ package org.apache.flink.streaming.api.checkpoint; -import org.apache.flink.annotation.PublicEvolving; +import org.apache.flink.annotation.Public; import org.apache.flink.api.common.functions.RuntimeContext; import org.apache.flink.api.common.state.KeyedStateStore; import org.apache.flink.api.common.state.OperatorStateStore; @@ -140,7 +140,7 @@ import org.apache.flink.runtime.state.FunctionSnapshotContext; * @see ListCheckpointed * @see RuntimeContext */ -@PublicEvolving +@Public public interface CheckpointedFunction { /**
