BlockManagerId (Spark 2.4.3 JavaDoc)

Object
- org.apache.spark.storage.BlockManagerId

All Implemented Interfaces:

java.io.Externalizable, java.io.Serializable
```
public class BlockManagerId
extends Object
implements java.io.Externalizable
```
:: DeveloperApi :: This class represent an unique identifier for a BlockManager.
The first 2 constructors of this class are made private to ensure that BlockManagerId objects can be created only using the apply method in the companion object. This allows de-duplication of ID objects. Also, constructor parameters are private to ensure that parameters cannot be modified from outside this class.

See Also:

Serialized Form

Method Summary

All Methods Static Methods Instance Methods Concrete Methods
Modifier and Type	Method and Description
`static BlockManagerId`	`apply(java.io.ObjectInput in)`
`static BlockManagerId`	`apply(String execId, String host, int port, scala.Option<String> topologyInfo)` Returns a `BlockManagerId` for the given configuration.
`static com.google.common.cache.LoadingCache<BlockManagerId,BlockManagerId>`	`blockManagerIdCache()` The max cache size is hardcoded to 10000, since the size of a BlockManagerId object is about 48B, the total memory cost should be below 1MB which is feasible.
`boolean`	`equals(Object that)`
`String`	`executorId()`
`static BlockManagerId`	`getCachedBlockManagerId(BlockManagerId id)`
`int`	`hashCode()`
`String`	`host()`
`String`	`hostPort()`
`boolean`	`isDriver()`
`int`	`port()`
`void`	`readExternal(java.io.ObjectInput in)`
`scala.Option<String>`	`topologyInfo()`
`String`	`toString()`
`void`	`writeExternal(java.io.ObjectOutput out)`

Methods inherited from class Object
getClass, notify, notifyAll, wait, wait, wait

- Method Detail
  - apply
```
public static BlockManagerId apply(String execId,
                                   String host,
                                   int port,
                                   scala.Option<String> topologyInfo)
```
    Returns a BlockManagerId for the given configuration.
    
    Parameters:
    
    execId - ID of the executor.
    
    host - Host name of the block manager.
    
    port - Port of the block manager.
    
    topologyInfo - topology information for the blockmanager, if available This can be network topology information for use while choosing peers while replicating data blocks. More information available here: TopologyMapper
    
    Returns:
    
    A new BlockManagerId.
  - apply
```
public static BlockManagerId apply(java.io.ObjectInput in)
```
  - blockManagerIdCache
```
public static com.google.common.cache.LoadingCache<BlockManagerId,BlockManagerId> blockManagerIdCache()
```
    The max cache size is hardcoded to 10000, since the size of a BlockManagerId object is about 48B, the total memory cost should be below 1MB which is feasible.
    
    Returns:
    
    (undocumented)
  - getCachedBlockManagerId
```
public static BlockManagerId getCachedBlockManagerId(BlockManagerId id)
```
  - executorId
```
public String executorId()
```
  - hostPort
```
public String hostPort()
```
  - host
```
public String host()
```
  - port
```
public int port()
```
  - topologyInfo
```
public scala.Option<String> topologyInfo()
```
  - isDriver
```
public boolean isDriver()
```
  - writeExternal
```
public void writeExternal(java.io.ObjectOutput out)
```
    Specified by:
    
    writeExternal in interface java.io.Externalizable
  - readExternal
```
public void readExternal(java.io.ObjectInput in)
```
    Specified by:
    
    readExternal in interface java.io.Externalizable
  - toString
```
public String toString()
```
    Overrides:
    
    toString in class Object
  - hashCode
```
public int hashCode()
```
    Overrides:
    
    hashCode in class Object
  - equals
```
public boolean equals(Object that)
```
    Overrides:
    
    equals in class Object

Class BlockManagerId

Method Summary

Methods inherited from class Object

Method Detail

apply

apply

blockManagerIdCache

getCachedBlockManagerId

executorId

hostPort

host

port

topologyInfo

isDriver

writeExternal

readExternal

toString

hashCode

equals