org.apache.spark.storage

Class BlockManagerId

java.lang.Object

org.apache.spark.storage.BlockManagerId

All Implemented Interfaces:

java.io.Externalizable, java.io.Serializable

public class BlockManagerId
extends java.lang.Object
implements java.io.Externalizable

:: DeveloperApi :: This class represent an unique identifier for a BlockManager.

The first 2 constructors of this class is 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

Methods

Modifier and Type	Method and Description
static BlockManagerId	apply(java.io.ObjectInput in)
static BlockManagerId	apply(java.lang.String execId, java.lang.String host, int port) Returns a BlockManagerId for the given configuration.
static java.util.concurrent.ConcurrentHashMap<BlockManagerId,BlockManagerId>	blockManagerIdCache()
boolean	equals(java.lang.Object that)
java.lang.String	executorId()
static BlockManagerId	getCachedBlockManagerId(BlockManagerId id)
int	hashCode()
java.lang.String	host()
java.lang.String	hostPort()
boolean	isDriver()
int	port()
void	readExternal(java.io.ObjectInput in)
java.lang.String	toString()
void	writeExternal(java.io.ObjectOutput out)

Methods inherited from class java.lang.Object

clone, finalize, getClass, notify, notifyAll, wait, wait, wait

Method Detail

apply

public static BlockManagerId apply(java.lang.String execId,
                   java.lang.String host,
                   int port)

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.

Returns:

A new BlockManagerId.

apply

public static BlockManagerId apply(java.io.ObjectInput in)

blockManagerIdCache

public static java.util.concurrent.ConcurrentHashMap<BlockManagerId,BlockManagerId> blockManagerIdCache()

getCachedBlockManagerId

public static BlockManagerId getCachedBlockManagerId(BlockManagerId id)

executorId

public java.lang.String executorId()

hostPort

public java.lang.String hostPort()

host

public java.lang.String host()

port

public int port()

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 java.lang.String toString()

Overrides:

toString in class java.lang.Object

hashCode

public int hashCode()

Overrides:

hashCode in class java.lang.Object

equals

public boolean equals(java.lang.Object that)

Overrides:

equals in class java.lang.Object