org.apache.spark.storage

Class BlockManagerMasterActor

Object

org.apache.spark.storage.BlockManagerMasterActor

All Implemented Interfaces:

akka.actor.Actor, Logging, ActorLogReceive

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

BlockManagerMasterActor is an actor on the master node to track statuses of all slaves' block managers.

Nested Class Summary

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

akka.actor.Actor.emptyBehavior$

Constructor Summary

Constructors

Constructor and Description
BlockManagerMasterActor(boolean isLocal, SparkConf conf, LiveListenerBus listenerBus)

Method Summary

Methods

Modifier and Type	Method and Description
long	checkTimeoutInterval()
boolean	isLocal()
void	preStart()
scala.PartialFunction<Object,scala.runtime.BoxedUnit>	receiveWithLogging()
long	slaveTimeout()
akka.actor.Cancellable	timeoutCheckingTask()

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

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

BlockManagerMasterActor

public BlockManagerMasterActor(boolean isLocal,
                       SparkConf conf,
                       LiveListenerBus listenerBus)

Method Detail

isLocal

public boolean isLocal()

slaveTimeout

public long slaveTimeout()

checkTimeoutInterval

public long checkTimeoutInterval()

timeoutCheckingTask

public akka.actor.Cancellable timeoutCheckingTask()

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