org.apache.spark.scheduler.local

Class LocalActor

Object

org.apache.spark.scheduler.local.LocalActor

All Implemented Interfaces:

akka.actor.Actor, Logging, ActorLogReceive

public class LocalActor
extends Object
implements akka.actor.Actor, ActorLogReceive, Logging

Calls to LocalBackend are all serialized through LocalActor. Using an actor makes the calls on LocalBackend asynchronous, which is necessary to prevent deadlock between LocalBackend and the TaskSchedulerImpl.

Nested Class Summary

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

akka.actor.Actor.emptyBehavior$

Constructor Summary

Constructors

Constructor and Description
LocalActor(TaskSchedulerImpl scheduler, LocalBackend executorBackend, int totalCores)

Method Summary

Methods

Modifier and Type	Method and Description
scala.PartialFunction<Object,scala.runtime.BoxedUnit>	receiveWithLogging()
void	reviveOffers()

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, preStart, receive, self, sender, supervisorStrategy, unhandled

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

log, receive

Methods inherited from interface org.apache.spark.Logging

initializeIfNecessary, initializeLogging, isTraceEnabled, log_, log, logDebug, logDebug, logError, logError, logInfo, logInfo, logName, logTrace, logTrace, logWarning, logWarning

Constructor Detail

LocalActor

public LocalActor(TaskSchedulerImpl scheduler,
          LocalBackend executorBackend,
          int totalCores)

Method Detail

receiveWithLogging

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

Specified by:

receiveWithLogging in interface ActorLogReceive

reviveOffers

public void reviveOffers()