public class LaunchCoordinator extends Object implements akka.actor.Actor, akka.actor.FSM<LaunchCoordinator.TaskState,LaunchCoordinator.GatherData>
The coordinator uses Netflix Fenzo to optimize task placement. During the GatheringOffers phase, offers are evaluated by Fenzo for suitability to the planned tasks. Reservations are then placed against the best offers, leading to revised offers containing reserved resources with which to launch task(s).
Modifier and Type | Class and Description |
---|---|
static class |
LaunchCoordinator.Assign
Informs the launch coordinator that some task(s) are assigned
to a host (for planning purposes).
|
static class |
LaunchCoordinator.Assign$ |
static class |
LaunchCoordinator.GatherData
FSM state data.
|
static class |
LaunchCoordinator.GatherData$ |
static class |
LaunchCoordinator.GatheringOffers$ |
static class |
LaunchCoordinator.Idle$ |
static class |
LaunchCoordinator.Launch
Instructs the launch coordinator to launch some new task.
|
static class |
LaunchCoordinator.Launch$ |
static class |
LaunchCoordinator.Suspended$ |
static interface |
LaunchCoordinator.TaskState
An FSM state of the launch coordinator.
|
static class |
LaunchCoordinator.Unassign
Informs the launch coordinator that some task is no longer assigned
to a host (for planning purposes).
|
static class |
LaunchCoordinator.Unassign$ |
akka.actor.FSM.$minus$greater$, akka.actor.FSM.CurrentState<S>, akka.actor.FSM.CurrentState$, akka.actor.FSM.Event<D>, akka.actor.FSM.Event$, akka.actor.FSM.Failure, akka.actor.FSM.Failure$, akka.actor.FSM.LogEntry<S,D>, akka.actor.FSM.LogEntry$, akka.actor.FSM.Normal$, akka.actor.FSM.NullFunction$, akka.actor.FSM.Reason, akka.actor.FSM.Shutdown$, akka.actor.FSM.State<S,D>, akka.actor.FSM.State$, akka.actor.FSM.StateTimeout$, akka.actor.FSM.StopEvent<S,D>, akka.actor.FSM.StopEvent$, akka.actor.FSM.SubscribeTransitionCallBack, akka.actor.FSM.SubscribeTransitionCallBack$, akka.actor.FSM.TimeoutMarker, akka.actor.FSM.TimeoutMarker$, akka.actor.FSM.Timer, akka.actor.FSM.Timer$, akka.actor.FSM.TransformHelper, akka.actor.FSM.Transition<S>, akka.actor.FSM.Transition$, akka.actor.FSM.UnsubscribeTransitionCallBack, akka.actor.FSM.UnsubscribeTransitionCallBack$
Constructor and Description |
---|
LaunchCoordinator(akka.actor.ActorRef manager,
Configuration config,
org.apache.mesos.SchedulerDriver schedulerDriver,
TaskSchedulerBuilder optimizerBuilder) |
Modifier and Type | Method and Description |
---|---|
static akka.actor.FSM.$minus$greater$ |
$minus$greater() |
static void |
applyState(akka.actor.FSM.State<S,D> nextState) |
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 void |
cancelTimer(String name) |
static akka.actor.ActorContext |
context() |
static <T extends LaunchCoordinator> |
createActorProps(Class<T> actorClass,
akka.actor.ActorRef manager,
Configuration flinkConfig,
org.apache.mesos.SchedulerDriver schedulerDriver,
TaskSchedulerBuilder optimizerBuilder)
Get the configuration properties for the launch coordinator.
|
static boolean |
debugEvent() |
static akka.actor.FSM.Event$ |
Event() |
static scala.concurrent.duration.FiniteDuration |
GATHER_DURATION() |
protected static void |
gossip(Object msg,
akka.actor.ActorRef sender) |
protected static akka.actor.ActorRef |
gossip$default$2(Object msg) |
static void |
initialize() |
static boolean |
isStateTimerActive() |
static boolean |
isTimerActive(String name) |
protected static scala.PartialFunction<Object,scala.runtime.BoxedUnit> |
listenerManagement() |
protected static Set<akka.actor.ActorRef> |
listeners() |
static akka.event.LoggingAdapter |
log() |
grizzled.slf4j.Logger |
LOG() |
protected static void |
logTermination(akka.actor.FSM.Reason reason) |
static void |
makeTransition(akka.actor.FSM.State<S,D> nextState) |
static D |
nextStateData() |
static void |
onTermination(scala.PartialFunction<akka.actor.FSM.StopEvent<S,D>,scala.runtime.BoxedUnit> terminationHandler) |
static void |
onTransition(scala.PartialFunction<scala.Tuple2<S,S>,scala.runtime.BoxedUnit> transitionHandler) |
com.netflix.fenzo.TaskScheduler |
optimizer()
The task placement optimizer.
|
static void |
postRestart(Throwable reason) |
void |
postStop() |
static void |
preRestart(Throwable reason,
scala.Option<Object> message) |
static void |
preStart() |
static void |
processEvent(akka.actor.FSM.Event<D> event,
Object source) |
static scala.PartialFunction<Object,scala.runtime.BoxedUnit> |
receive() |
static akka.actor.ActorRef |
self() |
static akka.actor.ActorRef |
sender() |
static void |
setStateTimeout(S state,
scala.Option<scala.concurrent.duration.FiniteDuration> timeout) |
static void |
setTimer(String name,
Object msg,
scala.concurrent.duration.FiniteDuration timeout,
boolean repeat) |
static boolean |
setTimer$default$4() |
static void |
startWith(S stateName,
D stateData,
scala.Option<scala.concurrent.duration.FiniteDuration> timeout) |
static scala.Option<scala.concurrent.duration.FiniteDuration> |
startWith$default$3() |
static D |
stateData() |
static S |
stateName() |
static akka.actor.FSM.StateTimeout$ |
StateTimeout() |
static akka.actor.FSM.State<S,D> |
stay() |
static akka.actor.FSM.State<S,D> |
stop() |
static akka.actor.FSM.State<S,D> |
stop(akka.actor.FSM.Reason reason) |
static akka.actor.FSM.State<S,D> |
stop(akka.actor.FSM.Reason reason,
D stateData) |
static akka.actor.FSM.StopEvent$ |
StopEvent() |
static akka.actor.SupervisorStrategy |
supervisorStrategy() |
static scala.PartialFunction<scala.Tuple2<S,S>,scala.runtime.BoxedUnit> |
total2pf(scala.Function2<S,S,scala.runtime.BoxedUnit> transitionHandler) |
static akka.actor.FSM.TransformHelper |
transform(scala.PartialFunction<akka.actor.FSM.Event<D>,akka.actor.FSM.State<S,D>> func) |
static void |
unhandled(Object message) |
static void |
when(S stateName,
scala.concurrent.duration.FiniteDuration stateTimeout,
scala.PartialFunction<akka.actor.FSM.Event<D>,akka.actor.FSM.State<S,D>> stateFunction) |
static scala.concurrent.duration.FiniteDuration |
when$default$2() |
static void |
whenUnhandled(scala.PartialFunction<akka.actor.FSM.Event<D>,akka.actor.FSM.State<S,D>> stateFunction) |
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
$minus$greater, akka$actor$FSM$_setter_$$minus$greater_$eq, akka$actor$FSM$_setter_$akka$actor$FSM$$handleEventDefault_$eq, akka$actor$FSM$_setter_$akka$actor$FSM$$stateFunctions_$eq, akka$actor$FSM$_setter_$akka$actor$FSM$$stateTimeouts_$eq, akka$actor$FSM$_setter_$akka$actor$FSM$$timerGen_$eq, akka$actor$FSM$_setter_$akka$actor$FSM$$timers_$eq, akka$actor$FSM$_setter_$Event_$eq, akka$actor$FSM$_setter_$StateTimeout_$eq, akka$actor$FSM$_setter_$StopEvent_$eq, akka$actor$FSM$$currentState_$eq, akka$actor$FSM$$currentState, akka$actor$FSM$$generation_$eq, akka$actor$FSM$$generation, akka$actor$FSM$$handleEvent_$eq, akka$actor$FSM$$handleEvent, akka$actor$FSM$$handleEventDefault, akka$actor$FSM$$nextState_$eq, akka$actor$FSM$$nextState, akka$actor$FSM$$stateFunctions, akka$actor$FSM$$stateTimeouts, akka$actor$FSM$$super$postStop, akka$actor$FSM$$terminateEvent_$eq, akka$actor$FSM$$terminateEvent, akka$actor$FSM$$timeoutFuture_$eq, akka$actor$FSM$$timeoutFuture, akka$actor$FSM$$timerGen, akka$actor$FSM$$timers, akka$actor$FSM$$transitionEvent_$eq, akka$actor$FSM$$transitionEvent, applyState, cancelTimer, debugEvent, Event, goto, initialize, isStateTimerActive, isTimerActive, logTermination, makeTransition, nextStateData, onTermination, onTransition, processEvent, receive, setStateTimeout, setTimer, setTimer$default$4, startWith, startWith$default$3, stateData, stateName, StateTimeout, stay, stop, stop, stop, StopEvent, total2pf, transform, when, when$default$2, whenUnhandled
akka$actor$Actor$_setter_$context_$eq, akka$actor$Actor$_setter_$self_$eq, aroundPostRestart, aroundPostStop, aroundPreRestart, aroundPreStart, aroundReceive, context, postRestart, preRestart, preStart, self, sender, supervisorStrategy, unhandled
public LaunchCoordinator(akka.actor.ActorRef manager, Configuration config, org.apache.mesos.SchedulerDriver schedulerDriver, TaskSchedulerBuilder optimizerBuilder)
public static scala.concurrent.duration.FiniteDuration GATHER_DURATION()
public static <T extends LaunchCoordinator> akka.actor.Props createActorProps(Class<T> actorClass, akka.actor.ActorRef manager, Configuration flinkConfig, org.apache.mesos.SchedulerDriver schedulerDriver, TaskSchedulerBuilder optimizerBuilder)
actorClass
- the launch coordinator actor class.flinkConfig
- the Flink configuration.schedulerDriver
- the Mesos scheduler driver.manager
- (undocumented)optimizerBuilder
- (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 akka.actor.SupervisorStrategy supervisorStrategy()
public static void preRestart(Throwable reason, scala.Option<Object> message) throws Exception
Exception
public static void unhandled(Object message)
protected static Set<akka.actor.ActorRef> listeners()
protected static scala.PartialFunction<Object,scala.runtime.BoxedUnit> listenerManagement()
protected static void gossip(Object msg, akka.actor.ActorRef sender)
protected static akka.actor.ActorRef gossip$default$2(Object msg)
public static akka.event.LoggingAdapter log()
public static akka.actor.FSM.Event$ Event()
public static akka.actor.FSM.StopEvent$ StopEvent()
public static akka.actor.FSM.$minus$greater$ $minus$greater()
public static akka.actor.FSM.StateTimeout$ StateTimeout()
public static final void when(S stateName, scala.concurrent.duration.FiniteDuration stateTimeout, scala.PartialFunction<akka.actor.FSM.Event<D>,akka.actor.FSM.State<S,D>> stateFunction)
public static final void startWith(S stateName, D stateData, scala.Option<scala.concurrent.duration.FiniteDuration> timeout)
public static final akka.actor.FSM.State<S,D> stay()
public static final akka.actor.FSM.State<S,D> stop()
public static final akka.actor.FSM.State<S,D> stop(akka.actor.FSM.Reason reason)
public static final akka.actor.FSM.State<S,D> stop(akka.actor.FSM.Reason reason, D stateData)
public static final akka.actor.FSM.TransformHelper transform(scala.PartialFunction<akka.actor.FSM.Event<D>,akka.actor.FSM.State<S,D>> func)
public static final void setTimer(String name, Object msg, scala.concurrent.duration.FiniteDuration timeout, boolean repeat)
public static final void cancelTimer(String name)
public static final boolean isTimerActive(String name)
public static final void setStateTimeout(S state, scala.Option<scala.concurrent.duration.FiniteDuration> timeout)
public static final boolean isStateTimerActive()
public static final void onTransition(scala.PartialFunction<scala.Tuple2<S,S>,scala.runtime.BoxedUnit> transitionHandler)
public static final scala.PartialFunction<scala.Tuple2<S,S>,scala.runtime.BoxedUnit> total2pf(scala.Function2<S,S,scala.runtime.BoxedUnit> transitionHandler)
public static final void onTermination(scala.PartialFunction<akka.actor.FSM.StopEvent<S,D>,scala.runtime.BoxedUnit> terminationHandler)
public static final void whenUnhandled(scala.PartialFunction<akka.actor.FSM.Event<D>,akka.actor.FSM.State<S,D>> stateFunction)
public static final void initialize()
public static final S stateName()
public static final D stateData()
public static final D nextStateData()
public static boolean debugEvent()
public static scala.PartialFunction<Object,scala.runtime.BoxedUnit> receive()
public static void processEvent(akka.actor.FSM.Event<D> event, Object source)
public static void applyState(akka.actor.FSM.State<S,D> nextState)
public static void makeTransition(akka.actor.FSM.State<S,D> nextState)
protected static void logTermination(akka.actor.FSM.Reason reason)
public static final scala.concurrent.duration.FiniteDuration when$default$2()
public static final scala.Option<scala.concurrent.duration.FiniteDuration> startWith$default$3()
public static final boolean setTimer$default$4()
public grizzled.slf4j.Logger LOG()
public com.netflix.fenzo.TaskScheduler optimizer()
The optimizer contains the following state: - unused offers - existing task placement (for fitness calculation involving task colocation)
public void postStop()
postStop
in interface akka.actor.Actor
postStop
in interface akka.actor.FSM<LaunchCoordinator.TaskState,LaunchCoordinator.GatherData>
Copyright © 2014–2018 The Apache Software Foundation. All rights reserved.