public class NetworkEnvironment extends Object
TaskManager
instance. The network environment contains
the data structures that keep track of all intermediate results and all data exchanges.
When initialized, the NetworkEnvironment will allocate the network buffer pool.
All other components (netty, intermediate result managers, ...) are only created once the
environment is "associated" with a TaskManager and JobManager. This happens as soon as the
TaskManager actor gets created and registers itself at the JobManager.Constructor and Description |
---|
NetworkEnvironment(scala.concurrent.ExecutionContext executionContext,
scala.concurrent.duration.FiniteDuration jobManagerTimeout,
NetworkEnvironmentConfiguration config)
Initializes all network I/O components.
|
Modifier and Type | Method and Description |
---|---|
void |
associateWithTaskManagerAndJobManager(ActorGateway jobManagerGateway,
ActorGateway taskManagerGateway)
This associates the network environment with a TaskManager and JobManager.
|
void |
disassociate() |
ConnectionManager |
getConnectionManager() |
IOManager.IOMode |
getDefaultIOMode() |
NetworkBufferPool |
getNetworkBufferPool() |
ResultPartitionConsumableNotifier |
getPartitionConsumableNotifier() |
ResultPartitionManager |
getPartitionManager() |
PartitionProducerStateChecker |
getPartitionProducerStateChecker() |
scala.Tuple2<Integer,Integer> |
getPartitionRequestInitialAndMaxBackoff() |
TaskEventDispatcher |
getTaskEventDispatcher() |
boolean |
isAssociated() |
boolean |
isShutdown() |
void |
registerTask(Task task) |
void |
shutdown()
Tries to shut down all network I/O components.
|
void |
unregisterTask(Task task) |
public NetworkEnvironment(scala.concurrent.ExecutionContext executionContext, scala.concurrent.duration.FiniteDuration jobManagerTimeout, NetworkEnvironmentConfiguration config) throws IOException
IOException
public ResultPartitionManager getPartitionManager()
public TaskEventDispatcher getTaskEventDispatcher()
public ConnectionManager getConnectionManager()
public NetworkBufferPool getNetworkBufferPool()
public IOManager.IOMode getDefaultIOMode()
public ResultPartitionConsumableNotifier getPartitionConsumableNotifier()
public PartitionProducerStateChecker getPartitionProducerStateChecker()
public scala.Tuple2<Integer,Integer> getPartitionRequestInitialAndMaxBackoff()
public boolean isAssociated()
public void associateWithTaskManagerAndJobManager(ActorGateway jobManagerGateway, ActorGateway taskManagerGateway) throws IOException
jobManagerGateway
- Gateway to the JobManager.taskManagerGateway
- Gateway to the TaskManager.IOException
- Thrown if the network subsystem (Netty) cannot be properly started.public void disassociate() throws IOException
IOException
public void registerTask(Task task) throws IOException
IOException
public void unregisterTask(Task task)
public void shutdown()
public boolean isShutdown()
Copyright © 2014–2017 The Apache Software Foundation. All rights reserved.