public class Tasks extends Object implements akka.actor.Actor
Routes messages between the scheduler and individual task monitor actors.
Constructor and Description |
---|
Tasks(Configuration flinkConfig,
org.apache.mesos.SchedulerDriver schedulerDriver,
scala.Function2<akka.actor.ActorRefFactory,TaskMonitor.TaskGoalState,akka.actor.ActorRef> taskMonitorCreator) |
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) |
static akka.actor.ActorContext |
context() |
static <T extends Tasks,M extends TaskMonitor> |
createActorProps(Class<T> actorClass,
Configuration flinkConfig,
org.apache.mesos.SchedulerDriver schedulerDriver,
Class<M> taskMonitorClass)
Create a tasks actor.
|
static void |
postRestart(Throwable reason) |
static void |
postStop() |
static void |
preRestart(Throwable reason,
scala.Option<Object> message) |
static void |
preStart() |
scala.PartialFunction<Object,scala.runtime.BoxedUnit> |
receive() |
scala.Option<Object> |
registered()
Cache of current connection state.
|
static akka.actor.ActorRef |
self() |
static akka.actor.ActorRef |
sender() |
akka.actor.SupervisorStrategy |
supervisorStrategy() |
scala.collection.mutable.Map<org.apache.mesos.Protos.TaskID,akka.actor.ActorRef> |
taskMap()
A map of task monitors by task ID.
|
static void |
unhandled(Object message) |
public Tasks(Configuration flinkConfig, org.apache.mesos.SchedulerDriver schedulerDriver, scala.Function2<akka.actor.ActorRefFactory,TaskMonitor.TaskGoalState,akka.actor.ActorRef> taskMonitorCreator)
public static <T extends Tasks,M extends TaskMonitor> akka.actor.Props createActorProps(Class<T> actorClass, Configuration flinkConfig, org.apache.mesos.SchedulerDriver schedulerDriver, Class<M> taskMonitorClass)
actorClass
- (undocumented)flinkConfig
- (undocumented)schedulerDriver
- (undocumented)taskMonitorClass
- (undocumented)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 void preRestart(Throwable reason, scala.Option<Object> message) throws Exception
Exception
public static void unhandled(Object message)
public scala.collection.mutable.Map<org.apache.mesos.Protos.TaskID,akka.actor.ActorRef> taskMap()
public scala.Option<Object> registered()
public akka.actor.SupervisorStrategy supervisorStrategy()
supervisorStrategy
in interface akka.actor.Actor
public scala.PartialFunction<Object,scala.runtime.BoxedUnit> receive()
receive
in interface akka.actor.Actor
Copyright © 2014–2018 The Apache Software Foundation. All rights reserved.