public class TestingTaskManager extends TaskManager implements TestingTaskManagerLike
TaskManager
to support testing messagesConstructor and Description |
---|
TestingTaskManager(TaskManagerConfiguration config,
InstanceConnectionInfo connectionInfo,
MemoryManager memoryManager,
IOManager ioManager,
NetworkEnvironment network,
int numberOfSlots,
LeaderRetrievalService leaderRetrievalService) |
TestingTaskManager(TaskManagerConfiguration config,
ResourceID resourceID,
InstanceConnectionInfo connectionInfo,
MemoryManager memoryManager,
IOManager ioManager,
NetworkEnvironment network,
int numberOfSlots,
LeaderRetrievalService leaderRetrievalService) |
askTimeout, bcVarManager, config, connectionInfo, currentJobManager, fileCache, getAndCheckJobManagerAddress, getTaskManagerRemoteReference, handleError, handleJobManagerDisconnect, handleMessage, HEARTBEAT_INTERVAL, ioManager, isConnected, leaderRetrievalService, leaderSessionID, log, LOG, main, MAX_STARTUP_CONNECT_TIME, memoryManager, network, notifyLeaderAddress, numberOfSlots, parseArgsAndLoadConfig, parseTaskManagerConfiguration, postStop, preStart, resourceID, resources, runningTasks, runTaskManager, runTaskManager, RUNTIME_FAILURE_RETURN_CODE, selectNetworkInterfaceAndPort, selectNetworkInterfaceAndRunTaskManager, sendHeartbeatToJobManager, shutdown, startTaskManagerComponentsAndActor, STARTUP_CONNECT_LOG_SUPPRESS, STARTUP_FAILURE_RETURN_CODE, TASK_MANAGER_NAME, triggerTaskManagerRegistration, unhandled
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
disconnectDisabled, handleMessage, handleTestingMessage, registeredSubmitTaskListeners, shutdown, unregisteredTasks, waitForJobManagerToBeTerminated, waitForRegisteredAtResourceManager, waitForRemoval, waitForRunning, waitForShutdown
decorateMessage, log, receive
akka$actor$Actor$_setter_$context_$eq, akka$actor$Actor$_setter_$self_$eq, aroundPostRestart, aroundPostStop, aroundPreRestart, aroundPreStart, aroundReceive, context, postRestart, postStop, preRestart, preStart, self, sender, supervisorStrategy, unhandled
decorateMessage, handleDiscardedMessage, receive
receive
public TestingTaskManager(TaskManagerConfiguration config, ResourceID resourceID, InstanceConnectionInfo connectionInfo, MemoryManager memoryManager, IOManager ioManager, NetworkEnvironment network, int numberOfSlots, LeaderRetrievalService leaderRetrievalService)
public TestingTaskManager(TaskManagerConfiguration config, InstanceConnectionInfo connectionInfo, MemoryManager memoryManager, IOManager ioManager, NetworkEnvironment network, int numberOfSlots, LeaderRetrievalService leaderRetrievalService)
Copyright © 2014–2017 The Apache Software Foundation. All rights reserved.