public class StorageStatus
extends Object
This class assumes BlockId and BlockStatus are immutable, such that the consumers of this class cannot mutate the source of the information. Accesses are not thread-safe.
Constructor and Description |
---|
StorageStatus(BlockManagerId blockManagerId,
long maxMemory,
scala.Option<Object> maxOnHeapMem,
scala.Option<Object> maxOffHeapMem)
Deprecated.
|
StorageStatus(BlockManagerId bmid,
long maxMemory,
scala.Option<Object> maxOnHeapMem,
scala.Option<Object> maxOffHeapMem,
scala.collection.Map<BlockId,BlockStatus> initialBlocks)
Deprecated.
Create a storage status with an initial set of blocks, leaving the source unmodified.
|
Modifier and Type | Method and Description |
---|---|
BlockManagerId |
blockManagerId()
Deprecated.
|
scala.collection.Map<BlockId,BlockStatus> |
blocks()
Deprecated.
Return the blocks stored in this block manager.
|
long |
cacheSize()
Deprecated.
Return the memory used by caching RDDs
|
boolean |
containsBlock(BlockId blockId)
Deprecated.
Return whether the given block is stored in this block manager in O(1) time.
|
long |
diskUsed()
Deprecated.
Return the disk space used by this block manager.
|
long |
diskUsedByRdd(int rddId)
Deprecated.
Return the disk space used by the given RDD in this block manager in O(1) time.
|
scala.Option<BlockStatus> |
getBlock(BlockId blockId)
Deprecated.
Return the given block stored in this block manager in O(1) time.
|
long |
maxMem()
Deprecated.
Return the max memory can be used by this block manager.
|
long |
maxMemory()
Deprecated.
|
scala.Option<Object> |
maxOffHeapMem()
Deprecated.
|
scala.Option<Object> |
maxOnHeapMem()
Deprecated.
|
long |
memRemaining()
Deprecated.
Return the memory remaining in this block manager.
|
long |
memUsed()
Deprecated.
Return the memory used by this block manager.
|
long |
memUsedByRdd(int rddId)
Deprecated.
Return the memory used by the given RDD in this block manager in O(1) time.
|
int |
numBlocks()
Deprecated.
Return the number of blocks stored in this block manager in O(RDDs) time.
|
int |
numRddBlocks()
Deprecated.
Return the number of RDD blocks stored in this block manager in O(RDDs) time.
|
int |
numRddBlocksById(int rddId)
Deprecated.
Return the number of blocks that belong to the given RDD in O(1) time.
|
scala.Option<Object> |
offHeapCacheSize()
Deprecated.
Return the memory used by off-heap caching RDDs
|
scala.Option<Object> |
offHeapMemRemaining()
Deprecated.
Return the off-heap memory remaining in this block manager.
|
scala.Option<Object> |
offHeapMemUsed()
Deprecated.
Return the off-heap memory used by this block manager.
|
scala.Option<Object> |
onHeapCacheSize()
Deprecated.
Return the memory used by on-heap caching RDDs
|
scala.Option<Object> |
onHeapMemRemaining()
Deprecated.
Return the on-heap memory remaining in this block manager.
|
scala.Option<Object> |
onHeapMemUsed()
Deprecated.
Return the on-heap memory used by this block manager.
|
scala.collection.Map<BlockId,BlockStatus> |
rddBlocks()
Deprecated.
Return the RDD blocks stored in this block manager.
|
scala.collection.Map<BlockId,BlockStatus> |
rddBlocksById(int rddId)
Deprecated.
Return the blocks that belong to the given RDD stored in this block manager.
|
scala.Option<StorageLevel> |
rddStorageLevel(int rddId)
Deprecated.
Return the storage level, if any, used by the given RDD in this block manager.
|
public StorageStatus(BlockManagerId blockManagerId, long maxMemory, scala.Option<Object> maxOnHeapMem, scala.Option<Object> maxOffHeapMem)
public StorageStatus(BlockManagerId bmid, long maxMemory, scala.Option<Object> maxOnHeapMem, scala.Option<Object> maxOffHeapMem, scala.collection.Map<BlockId,BlockStatus> initialBlocks)
public BlockManagerId blockManagerId()
public long maxMemory()
public scala.Option<Object> maxOnHeapMem()
public scala.Option<Object> maxOffHeapMem()
public scala.collection.Map<BlockId,BlockStatus> blocks()
public scala.collection.Map<BlockId,BlockStatus> rddBlocks()
public scala.collection.Map<BlockId,BlockStatus> rddBlocksById(int rddId)
public boolean containsBlock(BlockId blockId)
blockId
- (undocumented)this.blocks.contains
, which is O(blocks) time.public scala.Option<BlockStatus> getBlock(BlockId blockId)
blockId
- (undocumented)this.blocks.get
, which is O(blocks) time.public int numBlocks()
this.blocks.size
, which is O(blocks) time.public int numRddBlocks()
this.rddBlocks.size
, which is O(RDD blocks) time.public int numRddBlocksById(int rddId)
rddId
- (undocumented)this.rddBlocksById(rddId).size
, which is
O(blocks in this RDD) time.public long maxMem()
public long memRemaining()
public long cacheSize()
public long memUsed()
public scala.Option<Object> onHeapMemRemaining()
public scala.Option<Object> offHeapMemRemaining()
public scala.Option<Object> onHeapMemUsed()
public scala.Option<Object> offHeapMemUsed()
public scala.Option<Object> onHeapCacheSize()
public scala.Option<Object> offHeapCacheSize()
public long diskUsed()
public long memUsedByRdd(int rddId)
public long diskUsedByRdd(int rddId)
public scala.Option<StorageLevel> rddStorageLevel(int rddId)