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.Constructor and Description |
---|
NetworkEnvironment(NetworkBufferPool networkBufferPool,
ConnectionManager connectionManager,
ResultPartitionManager resultPartitionManager,
TaskEventDispatcher taskEventDispatcher,
KvStateRegistry kvStateRegistry,
KvStateServer kvStateServer,
IOManager.IOMode defaultIOMode,
int partitionRequestInitialBackoff,
int partitionRequestMaxBackoff) |
Modifier and Type | Method and Description |
---|---|
TaskKvStateRegistry |
createKvStateTaskRegistry(JobID jobId,
JobVertexID jobVertexId) |
ConnectionManager |
getConnectionManager() |
IOManager.IOMode |
getDefaultIOMode() |
KvStateRegistry |
getKvStateRegistry() |
KvStateServer |
getKvStateServer() |
NetworkBufferPool |
getNetworkBufferPool() |
int |
getPartitionRequestInitialBackoff() |
int |
getPartitionRequestMaxBackoff() |
ResultPartitionManager |
getResultPartitionManager() |
TaskEventDispatcher |
getTaskEventDispatcher() |
boolean |
isShutdown() |
void |
registerTask(Task task) |
void |
shutdown()
Tries to shut down all network I/O components.
|
void |
start() |
void |
unregisterTask(Task task) |
public NetworkEnvironment(NetworkBufferPool networkBufferPool, ConnectionManager connectionManager, ResultPartitionManager resultPartitionManager, TaskEventDispatcher taskEventDispatcher, KvStateRegistry kvStateRegistry, KvStateServer kvStateServer, IOManager.IOMode defaultIOMode, int partitionRequestInitialBackoff, int partitionRequestMaxBackoff)
public ResultPartitionManager getResultPartitionManager()
public TaskEventDispatcher getTaskEventDispatcher()
public ConnectionManager getConnectionManager()
public NetworkBufferPool getNetworkBufferPool()
public IOManager.IOMode getDefaultIOMode()
public int getPartitionRequestInitialBackoff()
public int getPartitionRequestMaxBackoff()
public KvStateRegistry getKvStateRegistry()
public KvStateServer getKvStateServer()
public TaskKvStateRegistry createKvStateTaskRegistry(JobID jobId, JobVertexID jobVertexId)
public void registerTask(Task task) throws IOException
IOException
public void unregisterTask(Task task)
public void start() throws IOException
IOException
public void shutdown()
public boolean isShutdown()
Copyright © 2014–2017 The Apache Software Foundation. All rights reserved.