public class BlockManagerMasterActor extends Object implements akka.actor.Actor, ActorLogReceive, Logging
Constructor and Description |
---|
BlockManagerMasterActor(boolean isLocal,
SparkConf conf,
LiveListenerBus listenerBus) |
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() |
equals, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
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
log, receive
initializeIfNecessary, initializeLogging, isTraceEnabled, log_, log, logDebug, logDebug, logError, logError, logInfo, logInfo, logName, logTrace, logTrace, logWarning, logWarning
public BlockManagerMasterActor(boolean isLocal, SparkConf conf, LiveListenerBus listenerBus)
public boolean isLocal()
public long slaveTimeout()
public long checkTimeoutInterval()
public akka.actor.Cancellable timeoutCheckingTask()
public void preStart()
preStart
in interface akka.actor.Actor
public scala.PartialFunction<Object,scala.runtime.BoxedUnit> receiveWithLogging()
receiveWithLogging
in interface ActorLogReceive