You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@flink.apache.org by ga...@apache.org on 2021/10/30 09:13:52 UTC
[flink-ml] 01/02: [hotfix][iteraton] Marks the EpochAware functions
as internal first
This is an automated email from the ASF dual-hosted git repository.
gaoyunhaii pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/flink-ml.git
commit 1dc646cdba8b3593bddde1656e83ea296dcf7d56
Author: Yun Gao <ga...@gmail.com>
AuthorDate: Fri Oct 29 23:07:09 2021 +0800
[hotfix][iteraton] Marks the EpochAware functions as internal first
---
.../flink/iteration/functions/EpochAwareAllRoundProcessFunction.java | 2 ++
.../apache/flink/iteration/functions/EpochAwareCoProcessFunction.java | 2 ++
2 files changed, 4 insertions(+)
diff --git a/flink-ml-iteration/src/main/java/org/apache/flink/iteration/functions/EpochAwareAllRoundProcessFunction.java b/flink-ml-iteration/src/main/java/org/apache/flink/iteration/functions/EpochAwareAllRoundProcessFunction.java
index a1df606..163da32 100644
--- a/flink-ml-iteration/src/main/java/org/apache/flink/iteration/functions/EpochAwareAllRoundProcessFunction.java
+++ b/flink-ml-iteration/src/main/java/org/apache/flink/iteration/functions/EpochAwareAllRoundProcessFunction.java
@@ -18,6 +18,7 @@
package org.apache.flink.iteration.functions;
+import org.apache.flink.annotation.Internal;
import org.apache.flink.iteration.operator.allround.EpochAware;
import org.apache.flink.streaming.api.functions.ProcessFunction;
import org.apache.flink.util.Collector;
@@ -28,6 +29,7 @@ import java.util.function.Supplier;
* A specialized {@link ProcessFunction} that also provide the attach epoch with each record. It is
* executed as all-round inside the iteration.
*/
+@Internal
public abstract class EpochAwareAllRoundProcessFunction<I, O> extends ProcessFunction<I, O>
implements EpochAware {
diff --git a/flink-ml-iteration/src/main/java/org/apache/flink/iteration/functions/EpochAwareCoProcessFunction.java b/flink-ml-iteration/src/main/java/org/apache/flink/iteration/functions/EpochAwareCoProcessFunction.java
index 26df622..405780c 100644
--- a/flink-ml-iteration/src/main/java/org/apache/flink/iteration/functions/EpochAwareCoProcessFunction.java
+++ b/flink-ml-iteration/src/main/java/org/apache/flink/iteration/functions/EpochAwareCoProcessFunction.java
@@ -18,6 +18,7 @@
package org.apache.flink.iteration.functions;
+import org.apache.flink.annotation.Internal;
import org.apache.flink.iteration.operator.allround.EpochAware;
import org.apache.flink.streaming.api.functions.co.CoProcessFunction;
import org.apache.flink.util.Collector;
@@ -28,6 +29,7 @@ import java.util.function.Supplier;
* A specialized {@link CoProcessFunction} that also provide the attach epoch with each record. It
* is executed as all-round inside the iteration.
*/
+@Internal
public abstract class EpochAwareCoProcessFunction<I1, I2, O> extends CoProcessFunction<I1, I2, O>
implements EpochAware {