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 <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 scala.concurrent.duration.FiniteDuration |
GATHER_DURATION() |
grizzled.slf4j.Logger |
LOG() |
com.netflix.fenzo.TaskScheduler |
optimizer()
The task placement optimizer.
|
void |
postStop() |
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.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–2017 The Apache Software Foundation. All rights reserved.