Class BlockManagerMessages.RegisterBlockManager

Object
org.apache.spark.storage.BlockManagerMessages.RegisterBlockManager
All Implemented Interfaces:
Serializable, BlockManagerMessages.ToBlockManagerMaster, scala.Equals, scala.Product, scala.Serializable
Enclosing class:
BlockManagerMessages

public static class BlockManagerMessages.RegisterBlockManager extends Object implements BlockManagerMessages.ToBlockManagerMaster, scala.Product, scala.Serializable
See Also:
  • Constructor Details

    • RegisterBlockManager

      public RegisterBlockManager(BlockManagerId blockManagerId, String[] localDirs, long maxOnHeapMemSize, long maxOffHeapMemSize, org.apache.spark.rpc.RpcEndpointRef sender, boolean isReRegister)
  • Method Details

    • blockManagerId

      public BlockManagerId blockManagerId()
    • localDirs

      public String[] localDirs()
    • maxOnHeapMemSize

      public long maxOnHeapMemSize()
    • maxOffHeapMemSize

      public long maxOffHeapMemSize()
    • sender

      public org.apache.spark.rpc.RpcEndpointRef sender()
    • isReRegister

      public boolean isReRegister()