public class MesosTaskManager extends TaskManager
Constructor and Description |
---|
MesosTaskManager(TaskManagerConfiguration config,
ResourceID resourceID,
TaskManagerLocation taskManagerLocation,
MemoryManager memoryManager,
IOManager ioManager,
NetworkEnvironment network,
int numberOfSlots,
LeaderRetrievalService leaderRetrievalService,
MetricRegistry metricRegistry) |
Modifier and Type | Method and Description |
---|---|
scala.PartialFunction<Object,scala.runtime.BoxedUnit> |
handleMessage()
Central handling of actor messages.
|
static void |
main(String[] args)
Entry point (main method) to run the TaskManager on Mesos.
|
askTimeout, bcVarManager, config, createTaskManagerComponents, currentJobManager, fileCache, getAndCheckJobManagerAddress, getTaskManagerProps, getTaskManagerRemoteReference, handleError, handleJobManagerDisconnect, HEARTBEAT_INTERVAL, ioManager, isConnected, leaderRetrievalService, leaderSessionID, location, log, LOG, MAX_STARTUP_CONNECT_TIME, memoryManager, metricsRegistry, 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
decorateMessage, handleDiscardedMessage, receive
receive
public MesosTaskManager(TaskManagerConfiguration config, ResourceID resourceID, TaskManagerLocation taskManagerLocation, MemoryManager memoryManager, IOManager ioManager, NetworkEnvironment network, int numberOfSlots, LeaderRetrievalService leaderRetrievalService, MetricRegistry metricRegistry)
public static void main(String[] args)
args
- The command line arguments.public scala.PartialFunction<Object,scala.runtime.BoxedUnit> handleMessage()
TaskManager
handleMessage
in interface FlinkActor
handleMessage
in class TaskManager
Copyright © 2014–2017 The Apache Software Foundation. All rights reserved.