Uses of Class
org.apache.flink.runtime.broadcast.BroadcastVariableManager

Packages that use BroadcastVariableManager

Package	Description
org.apache.flink.runtime.execution
org.apache.flink.runtime.taskmanager

Uses of BroadcastVariableManager in org.apache.flink.runtime.execution

Methods in org.apache.flink.runtime.execution that return BroadcastVariableManager

Modifier and Type	Method and Description
BroadcastVariableManager	Environment.getBroadcastVariableManager()

Uses of BroadcastVariableManager in org.apache.flink.runtime.taskmanager

Methods in org.apache.flink.runtime.taskmanager that return BroadcastVariableManager

Modifier and Type	Method and Description
BroadcastVariableManager	RuntimeEnvironment.getBroadcastVariableManager()

Constructors in org.apache.flink.runtime.taskmanager with parameters of type BroadcastVariableManager

Constructor and Description
RuntimeEnvironment(org.apache.flink.api.common.JobID jobId, JobVertexID jobVertexId, ExecutionAttemptID executionId, String taskName, String taskNameWithSubtasks, int subtaskIndex, int parallelism, org.apache.flink.configuration.Configuration jobConfiguration, org.apache.flink.configuration.Configuration taskConfiguration, ClassLoader userCodeClassLoader, MemoryManager memManager, IOManager ioManager, BroadcastVariableManager bcVarManager, InputSplitProvider splitProvider, Map<String,Future<org.apache.flink.core.fs.Path>> distCacheEntries, ResultPartitionWriter[] writers, InputGate[] inputGates, akka.actor.ActorRef jobManagerActor)
Task(TaskDeploymentDescriptor tdd, MemoryManager memManager, IOManager ioManager, NetworkEnvironment networkEnvironment, BroadcastVariableManager bcVarManager, akka.actor.ActorRef taskManagerActor, akka.actor.ActorRef jobManagerActor, scala.concurrent.duration.FiniteDuration actorAskTimeout, LibraryCacheManager libraryCache, FileCache fileCache) IMPORTANT: This constructor may not start any work that would need to be undone in the case of a failing task deployment.