public class MesosTaskManager extends TaskManager
Constructor and Description |
---|
MesosTaskManager(TaskManagerConfiguration config,
ResourceID resourceID,
TaskManagerLocation taskManagerLocation,
MemoryManager memoryManager,
IOManager ioManager,
NetworkEnvironment network,
int numberOfSlots,
HighAvailabilityServices highAvailabilityServices,
MetricRegistry metricRegistry) |
Modifier and Type | Method and Description |
---|---|
protected static void |
aroundPostRestart(Throwable reason) |
protected static void |
aroundPostStop() |
protected static void |
aroundPreRestart(Throwable reason,
scala.Option<Object> message) |
protected static void |
aroundPreStart() |
protected static void |
aroundReceive(scala.PartialFunction<Object,scala.runtime.BoxedUnit> receive,
Object msg) |
protected static akka.util.Timeout |
askTimeout() |
protected static BroadcastVariableManager |
bcVarManager() |
protected static TaskManagerConfiguration |
config() |
static akka.actor.ActorContext |
context() |
protected static void |
currentJobManager_$eq(scala.Option<akka.actor.ActorRef> x$1) |
protected static scala.Option<akka.actor.ActorRef> |
currentJobManager() |
static Object |
decorateMessage(Object message) |
protected static FileCache |
fileCache() |
static void |
handleError(Exception exception) |
protected static void |
handleJobManagerDisconnect(String msg) |
scala.PartialFunction<Object,scala.runtime.BoxedUnit> |
handleMessage()
Central handling of actor messages.
|
protected static HighAvailabilityServices |
highAvailabilityServices() |
protected static IOManager |
ioManager() |
protected static boolean |
isConnected() |
protected static LeaderRetrievalService |
leaderRetrievalService() |
static void |
leaderSessionID_$eq(scala.Option<UUID> x$1) |
static scala.Option<UUID> |
leaderSessionID() |
protected static TaskManagerLocation |
location() |
static grizzled.slf4j.Logger |
log() |
static void |
main(String[] args)
Entry point (main method) to run the TaskManager on Mesos.
|
protected static MemoryManager |
memoryManager() |
protected static MetricRegistry |
metricsRegistry() |
protected static NetworkEnvironment |
network() |
static void |
notifyLeaderAddress(String leaderAddress,
UUID leaderSessionID) |
protected static int |
numberOfSlots() |
static void |
postRestart(Throwable reason) |
static void |
postStop() |
static void |
preRestart(Throwable reason,
scala.Option<Object> message) |
static void |
preStart() |
static scala.PartialFunction<Object,scala.runtime.BoxedUnit> |
receive() |
protected static ResourceID |
resourceID() |
protected static HardwareDescription |
resources() |
protected static HashMap<ExecutionAttemptID,Task> |
runningTasks() |
static akka.actor.ActorRef |
self() |
static akka.actor.ActorRef |
sender() |
protected static void |
sendHeartbeatToJobManager() |
protected static void |
shutdown() |
static akka.actor.SupervisorStrategy |
supervisorStrategy() |
static void |
triggerTaskManagerRegistration() |
static void |
unhandled(Object message) |
askTimeout, bcVarManager, config, currentJobManager, fileCache, getTaskManagerProps, getTaskManagerRemoteReference, handleError, handleJobManagerDisconnect, HEARTBEAT_INTERVAL, highAvailabilityServices, ioManager, isConnected, leaderRetrievalService, leaderSessionID, location, log, LOG, MAX_STARTUP_CONNECT_TIME, memoryManager, metricsRegistry, network, notifyLeaderAddress, numberOfSlots, parseArgsAndLoadConfig, postStop, preStart, resourceID, resources, runningTasks, runTaskManager, runTaskManager, RUNTIME_FAILURE_RETURN_CODE, selectNetworkInterfaceAndPort, selectNetworkInterfaceAndRunTaskManager, sendHeartbeatToJobManager, shutdown, startTaskManagerComponentsAndActor, STARTUP_CONNECT_LOG_SUPPRESS, STARTUP_FAILURE_RETURN_CODE, triggerTaskManagerRegistration, unhandled
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
decorateMessage, handleDiscardedMessage, handleNoLeaderId, receive
receive
public MesosTaskManager(TaskManagerConfiguration config, ResourceID resourceID, TaskManagerLocation taskManagerLocation, MemoryManager memoryManager, IOManager ioManager, NetworkEnvironment network, int numberOfSlots, HighAvailabilityServices highAvailabilityServices, MetricRegistry metricRegistry)
public static void main(String[] args)
args
- The command line arguments.public static akka.actor.ActorContext context()
public static final akka.actor.ActorRef self()
public static final akka.actor.ActorRef sender()
protected static void aroundReceive(scala.PartialFunction<Object,scala.runtime.BoxedUnit> receive, Object msg)
protected static void aroundPreStart()
protected static void aroundPostStop()
protected static void aroundPreRestart(Throwable reason, scala.Option<Object> message)
protected static void aroundPostRestart(Throwable reason)
public static akka.actor.SupervisorStrategy supervisorStrategy()
public static void preRestart(Throwable reason, scala.Option<Object> message) throws Exception
Exception
public static scala.PartialFunction<Object,scala.runtime.BoxedUnit> receive()
protected static TaskManagerConfiguration config()
protected static ResourceID resourceID()
protected static TaskManagerLocation location()
protected static MemoryManager memoryManager()
protected static IOManager ioManager()
protected static NetworkEnvironment network()
protected static int numberOfSlots()
protected static HighAvailabilityServices highAvailabilityServices()
protected static MetricRegistry metricsRegistry()
public static grizzled.slf4j.Logger log()
protected static akka.util.Timeout askTimeout()
protected static HardwareDescription resources()
protected static HashMap<ExecutionAttemptID,Task> runningTasks()
protected static BroadcastVariableManager bcVarManager()
protected static FileCache fileCache()
protected static LeaderRetrievalService leaderRetrievalService()
protected static scala.Option<akka.actor.ActorRef> currentJobManager()
protected static void currentJobManager_$eq(scala.Option<akka.actor.ActorRef> x$1)
public static scala.Option<UUID> leaderSessionID()
public static void leaderSessionID_$eq(scala.Option<UUID> x$1)
public static void preStart()
public static void postStop()
public static void unhandled(Object message)
protected static boolean isConnected()
protected static void handleJobManagerDisconnect(String msg)
protected static void sendHeartbeatToJobManager()
public static void notifyLeaderAddress(String leaderAddress, UUID leaderSessionID)
public static void triggerTaskManagerRegistration()
public static void handleError(Exception exception)
protected static void shutdown()
public scala.PartialFunction<Object,scala.runtime.BoxedUnit> handleMessage()
TaskManager
handleMessage
in interface FlinkActor
handleMessage
in class TaskManager
Copyright © 2014–2018 The Apache Software Foundation. All rights reserved.