You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@flink.apache.org by se...@apache.org on 2020/06/24 18:42:52 UTC
[flink] 03/04: [FLINK-18430][DataStream API] Classify
CheckpointedFunction and CheckpointListener as @Public
This is an automated email from the ASF dual-hosted git repository.
sewen pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/flink.git
commit 95b9adbeaa7058c4fc804a5277cbaa958485d63b
Author: Stephan Ewen <se...@apache.org>
AuthorDate: Wed Jun 24 18:07:22 2020 +0200
[FLINK-18430][DataStream API] Classify CheckpointedFunction and CheckpointListener as @Public
This closes #12767
---
.../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 {
/**