org.apache.spark.storage

Class BlockManagerInfo

Object

org.apache.spark.storage.BlockManagerInfo

All Implemented Interfaces:

Logging

public class BlockManagerInfo
extends Object
implements Logging

Constructor Summary

Constructors

Constructor and Description
BlockManagerInfo(BlockManagerId blockManagerId, long timeMs, long maxMem, akka.actor.ActorRef slaveActor)

Method Summary

Methods

Modifier and Type	Method and Description
BlockManagerId	blockManagerId()
java.util.HashMap<BlockId,BlockStatus>	blocks()
void	clear()
scala.Option<BlockStatus>	getStatus(BlockId blockId)
long	lastSeenMs()
long	maxMem()
long	remainingMem()
void	removeBlock(BlockId blockId)
akka.actor.ActorRef	slaveActor()
String	toString()
void	updateBlockInfo(BlockId blockId, StorageLevel storageLevel, long memSize, long diskSize, long tachyonSize)
void	updateLastSeenMs()

Methods inherited from class Object

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

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

BlockManagerInfo

public BlockManagerInfo(BlockManagerId blockManagerId,
                long timeMs,
                long maxMem,
                akka.actor.ActorRef slaveActor)

Method Detail

blockManagerId

public BlockManagerId blockManagerId()

maxMem

public long maxMem()

slaveActor

public akka.actor.ActorRef slaveActor()

getStatus

public scala.Option<BlockStatus> getStatus(BlockId blockId)

updateLastSeenMs

public void updateLastSeenMs()

updateBlockInfo

public void updateBlockInfo(BlockId blockId,
                   StorageLevel storageLevel,
                   long memSize,
                   long diskSize,
                   long tachyonSize)

removeBlock

public void removeBlock(BlockId blockId)

remainingMem

public long remainingMem()

lastSeenMs

public long lastSeenMs()

blocks

public java.util.HashMap<BlockId,BlockStatus> blocks()

toString

public String toString()

Overrides:

toString in class Object

clear

public void clear()