[flink-ml] 03/03: [hotfix] Mark BroadcastUtils as internal

[ga...@apache.org]

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 <ga...@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,