StorageStatus

Value Members

1. final def !=(arg0: Any): Boolean

   

   Definition Classes

   AnyRef → Any

2. final def ##(): Int

   

   Definition Classes

   AnyRef → Any

3. final def ==(arg0: Any): Boolean

   

   Definition Classes

   AnyRef → Any

4. final def asInstanceOf[T0]: T0

   

   Definition Classes

   Any

5. val blockManagerId: BlockManagerId

   

6. def blocks: Map[BlockId, BlockStatus]

   

   Return the blocks stored in this block manager.

   Return the blocks stored in this block manager.

   Note

   This is somewhat expensive, as it involves cloning the underlying maps and then concatenating them together. Much faster alternatives exist for common operations such as contains, get, and size.

7. def cacheSize: Long

   

   Return the memory used by caching RDDs

8. def clone(): AnyRef

   

   Attributes

   protected[java.lang]

   Definition Classes

   AnyRef

   Annotations

   @throws( ... )

9. def containsBlock(blockId: BlockId): Boolean

   

   Return whether the given block is stored in this block manager in O(1) time.

   Return whether the given block is stored in this block manager in O(1) time.

   Note

   This is much faster than this.blocks.contains, which is O(blocks) time.

10. def diskUsed: Long

    

    Return the disk space used by this block manager.

11. def diskUsedByRdd(rddId: Int): Long

    

    Return the disk space used by the given RDD in this block manager in O(1) time.

12. final def eq(arg0: AnyRef): Boolean

    

    Definition Classes

    AnyRef

13. def equals(arg0: Any): Boolean

    

    Definition Classes

    AnyRef → Any

14. def finalize(): Unit

    

    Attributes

    protected[java.lang]

    Definition Classes

    AnyRef

    Annotations

    @throws( classOf[java.lang.Throwable] )

15. def getBlock(blockId: BlockId): Option[BlockStatus]

    

    Return the given block stored in this block manager in O(1) time.

    Return the given block stored in this block manager in O(1) time.

    Note

    This is much faster than this.blocks.get, which is O(blocks) time.

16. final def getClass(): Class[_]

    

    Definition Classes

    AnyRef → Any

17. def hashCode(): Int

    

    Definition Classes

    AnyRef → Any

18. final def isInstanceOf[T0]: Boolean

    

    Definition Classes

    Any

19. def maxMem: Long

    

    Return the max memory can be used by this block manager.

20. val maxMemory: Long

    

21. val maxOffHeapMem: Option[Long]

    

22. val maxOnHeapMem: Option[Long]

    

23. def memRemaining: Long

    

    Return the memory remaining in this block manager.

24. def memUsed: Long

    

    Return the memory used by this block manager.

25. def memUsedByRdd(rddId: Int): Long

    

    Return the memory used by the given RDD in this block manager in O(1) time.

26. final def ne(arg0: AnyRef): Boolean

    

    Definition Classes

    AnyRef

27. final def notify(): Unit

    

    Definition Classes

    AnyRef

28. final def notifyAll(): Unit

    

    Definition Classes

    AnyRef

29. def numBlocks: Int

    

    Return the number of blocks stored in this block manager in O(RDDs) time.

    Return the number of blocks stored in this block manager in O(RDDs) time.

    Note

    This is much faster than this.blocks.size, which is O(blocks) time.

30. def numRddBlocks: Int

    

    Return the number of RDD blocks stored in this block manager in O(RDDs) time.

    Return the number of RDD blocks stored in this block manager in O(RDDs) time.

    Note

    This is much faster than this.rddBlocks.size, which is O(RDD blocks) time.

31. def numRddBlocksById(rddId: Int): Int

    

    Return the number of blocks that belong to the given RDD in O(1) time.

    Return the number of blocks that belong to the given RDD in O(1) time.

    Note

    This is much faster than this.rddBlocksById(rddId).size, which is O(blocks in this RDD) time.

32. def offHeapCacheSize: Option[Long]

    

    Return the memory used by off-heap caching RDDs

33. def offHeapMemRemaining: Option[Long]

    

    Return the off-heap memory remaining in this block manager.

34. def offHeapMemUsed: Option[Long]

    

    Return the off-heap memory used by this block manager.

35. def onHeapCacheSize: Option[Long]

    

    Return the memory used by on-heap caching RDDs

36. def onHeapMemRemaining: Option[Long]

    

    Return the on-heap memory remaining in this block manager.

37. def onHeapMemUsed: Option[Long]

    

    Return the on-heap memory used by this block manager.

38. def rddBlocks: Map[BlockId, BlockStatus]

    

    Return the RDD blocks stored in this block manager.

    Return the RDD blocks stored in this block manager.

    Note

    This is somewhat expensive, as it involves cloning the underlying maps and then concatenating them together. Much faster alternatives exist for common operations such as getting the memory, disk, and off-heap memory sizes occupied by this RDD.

39. def rddBlocksById(rddId: Int): Map[BlockId, BlockStatus]

    

    Return the blocks that belong to the given RDD stored in this block manager.

40. def rddStorageLevel(rddId: Int): Option[StorageLevel]

    

    Return the storage level, if any, used by the given RDD in this block manager.

41. final def synchronized[T0](arg0: ⇒ T0): T0

    

    Definition Classes

    AnyRef

42. def toString(): String

    

    Definition Classes

    AnyRef → Any

43. final def wait(): Unit

    

    Definition Classes

    AnyRef

    Annotations

    @throws( ... )

44. final def wait(arg0: Long, arg1: Int): Unit

    

    Definition Classes

    AnyRef

    Annotations

    @throws( ... )

45. final def wait(arg0: Long): Unit

    

    Definition Classes

    AnyRef

    Annotations

    @throws( ... )