public class BroadcastContext extends Object
Constructor and Description |
---|
BroadcastContext() |
Modifier and Type | Method and Description |
---|---|
static <T> List<T> |
getBroadcastVariable(String key) |
static boolean |
isCacheFinished(String key) |
static void |
notifyCacheFinished(String key) |
static void |
putBroadcastVariable(String key,
org.apache.flink.api.java.tuple.Tuple2<Boolean,List<?>> variable) |
static void |
putMailBoxExecutor(String key,
org.apache.flink.api.common.operators.MailboxExecutor mailboxExecutor) |
static void |
remove(String key) |
@VisibleForTesting public static void putBroadcastVariable(String key, org.apache.flink.api.java.tuple.Tuple2<Boolean,List<?>> variable)
@VisibleForTesting public static void putMailBoxExecutor(String key, org.apache.flink.api.common.operators.MailboxExecutor mailboxExecutor)
@VisibleForTesting public static void remove(String key)
@VisibleForTesting public static void notifyCacheFinished(String key)
@VisibleForTesting public static boolean isCacheFinished(String key)
Copyright © 2019–2023 The Apache Software Foundation. All rights reserved.