public class BroadcastStreamingRuntimeContext
extends org.apache.flink.streaming.api.operators.StreamingRuntimeContext
StreamingRuntimeContext
that provides accessibility of broadcast
variables.Constructor and Description |
---|
BroadcastStreamingRuntimeContext(org.apache.flink.runtime.execution.Environment env,
Map<String,org.apache.flink.api.common.accumulators.Accumulator<?,?>> accumulators,
org.apache.flink.metrics.groups.OperatorMetricGroup operatorMetricGroup,
org.apache.flink.runtime.jobgraph.OperatorID operatorID,
org.apache.flink.streaming.runtime.tasks.ProcessingTimeService processingTimeService,
org.apache.flink.api.common.state.KeyedStateStore keyedStateStore,
org.apache.flink.runtime.externalresource.ExternalResourceInfoProvider externalResourceInfoProvider) |
Modifier and Type | Method and Description |
---|---|
<RT> List<RT> |
getBroadcastVariable(String name) |
<T,C> C |
getBroadcastVariableWithInitializer(String name,
org.apache.flink.api.common.functions.BroadcastVariableInitializer<T,C> initializer) |
boolean |
hasBroadcastVariable(String name) |
void |
setBroadcastVariable(String name,
List<?> broadcastVariable) |
getAggregatingState, getCheckpointMode, getExternalResourceInfos, getGlobalAggregateManager, getInputSplitProvider, getJobId, getListState, getMapState, getOperatorUniqueID, getProcessingTimeService, getReducingState, getState, getTaskManagerRuntimeInfo, isCheckpointingEnabled, setKeyedStateStore
addAccumulator, getAccumulator, getAllocationIDAsString, getAttemptNumber, getDistributedCache, getDoubleCounter, getExecutionConfig, getHistogram, getIndexOfThisSubtask, getIntCounter, getLongCounter, getMaxNumberOfParallelSubtasks, getMetricGroup, getNumberOfParallelSubtasks, getTaskName, getTaskNameWithSubtasks, getUserCodeClassLoader, registerUserCodeClassLoaderReleaseHookIfAbsent
public BroadcastStreamingRuntimeContext(org.apache.flink.runtime.execution.Environment env, Map<String,org.apache.flink.api.common.accumulators.Accumulator<?,?>> accumulators, org.apache.flink.metrics.groups.OperatorMetricGroup operatorMetricGroup, org.apache.flink.runtime.jobgraph.OperatorID operatorID, org.apache.flink.streaming.runtime.tasks.ProcessingTimeService processingTimeService, @Nullable org.apache.flink.api.common.state.KeyedStateStore keyedStateStore, org.apache.flink.runtime.externalresource.ExternalResourceInfoProvider externalResourceInfoProvider)
public boolean hasBroadcastVariable(String name)
hasBroadcastVariable
in interface org.apache.flink.api.common.functions.RuntimeContext
hasBroadcastVariable
in class org.apache.flink.streaming.api.operators.StreamingRuntimeContext
public <RT> List<RT> getBroadcastVariable(String name)
getBroadcastVariable
in interface org.apache.flink.api.common.functions.RuntimeContext
getBroadcastVariable
in class org.apache.flink.streaming.api.operators.StreamingRuntimeContext
public <T,C> C getBroadcastVariableWithInitializer(String name, org.apache.flink.api.common.functions.BroadcastVariableInitializer<T,C> initializer)
getBroadcastVariableWithInitializer
in interface org.apache.flink.api.common.functions.RuntimeContext
getBroadcastVariableWithInitializer
in class org.apache.flink.streaming.api.operators.StreamingRuntimeContext
Copyright © 2019–2023 The Apache Software Foundation. All rights reserved.