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 2edf453251c7ed9d8d1778c9c0115194e3d13ca7 Author: Yun Gao <gaoyunhen...@gmail.com> AuthorDate: Mon Nov 15 11:36:30 2021 +0800 [hotfix] Mark BroadcastUtils as internal --- .../java/org/apache/flink/ml/common/broadcast/BroadcastUtils.java | 5 +++-- 1 file changed, 3 insertions(+), 2 deletions(-) diff --git a/flink-ml-lib/src/main/java/org/apache/flink/ml/common/broadcast/BroadcastUtils.java b/flink-ml-lib/src/main/java/org/apache/flink/ml/common/broadcast/BroadcastUtils.java index bb12647..7315e4e 100644 --- a/flink-ml-lib/src/main/java/org/apache/flink/ml/common/broadcast/BroadcastUtils.java +++ b/flink-ml-lib/src/main/java/org/apache/flink/ml/common/broadcast/BroadcastUtils.java @@ -18,7 +18,7 @@ package org.apache.flink.ml.common.broadcast; -import org.apache.flink.annotation.PublicEvolving; +import org.apache.flink.annotation.Internal; import org.apache.flink.api.common.typeinfo.TypeInformation; import org.apache.flink.iteration.compile.DraftExecutionEnvironment; import org.apache.flink.ml.common.broadcast.operator.BroadcastVariableReceiverOperatorFactory; @@ -40,6 +40,7 @@ import java.util.UUID; import java.util.function.Function; /** Utility class to support withBroadcast in DataStream. */ +@Internal public class BroadcastUtils { /** * supports withBroadcastStream in DataStream API. Broadcast data streams are available at all @@ -62,7 +63,7 @@ public class BroadcastUtils { * operator in this function, otherwise it raises an exception. * @return the output data stream. */ - @PublicEvolving + @Internal public static <OUT> DataStream<OUT> withBroadcastStream( List<DataStream<?>> inputList, Map<String, DataStream<?>> bcStreams,