org.apache.spark.scheduler.cluster

Class CoarseGrainedSchedulerBackend.DriverActor

Object

org.apache.spark.scheduler.cluster.CoarseGrainedSchedulerBackend.DriverActor

All Implemented Interfaces:

akka.actor.Actor, ActorLogReceive

Enclosing class:

CoarseGrainedSchedulerBackend

public class CoarseGrainedSchedulerBackend.DriverActor
extends Object
implements akka.actor.Actor, ActorLogReceive

Nested Class Summary

Nested classes/interfaces inherited from interface akka.actor.Actor

akka.actor.Actor.emptyBehavior$

Constructor Summary

Constructors

Constructor and Description
CoarseGrainedSchedulerBackend.DriverActor(scala.collection.Seq<scala.Tuple2<String,String>> sparkProperties)

Method Summary

Methods

Modifier and Type	Method and Description
void	launchTasks(scala.collection.Seq<scala.collection.Seq<TaskDescription>> tasks)
void	makeOffers()
void	makeOffers(String executorId)
void	preStart()
scala.PartialFunction<Object,scala.runtime.BoxedUnit>	receiveWithLogging()
void	removeExecutor(String executorId, String reason)

Methods inherited from class Object

equals, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Methods inherited from interface akka.actor.Actor

akka$actor$Actor$_setter_$context_$eq, akka$actor$Actor$_setter_$self_$eq, aroundPostRestart, aroundPostStop, aroundPreRestart, aroundPreStart, aroundReceive, context, postRestart, postStop, preRestart, receive, self, sender, supervisorStrategy, unhandled

Methods inherited from interface org.apache.spark.util.ActorLogReceive

receive

Constructor Detail

CoarseGrainedSchedulerBackend.DriverActor

public CoarseGrainedSchedulerBackend.DriverActor(scala.collection.Seq<scala.Tuple2<String,String>> sparkProperties)

Method Detail

preStart

public void preStart()

Specified by:

preStart in interface akka.actor.Actor

receiveWithLogging

public scala.PartialFunction<Object,scala.runtime.BoxedUnit> receiveWithLogging()

Specified by:

receiveWithLogging in interface ActorLogReceive

makeOffers

public void makeOffers()

makeOffers

public void makeOffers(String executorId)

launchTasks

public void launchTasks(scala.collection.Seq<scala.collection.Seq<TaskDescription>> tasks)

removeExecutor

public void removeExecutor(String executorId,
                  String reason)