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 |
---|---|
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.
|
scala.PartialFunction<Object,scala.runtime.BoxedUnit> |
receive() |
scala.Option<Object> |
registered()
Cache of current connection state.
|
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.
|
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)
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–2017 The Apache Software Foundation. All rights reserved.