org.apache.spark.storage

Class BlockId

Object

org.apache.spark.storage.BlockId

Direct Known Subclasses:

BroadcastBlockId, RDDBlockId, ShuffleBlockId, ShuffleIndexBlockId, StreamBlockId, TaskResultBlockId

public abstract class BlockId
extends Object

:: DeveloperApi :: Identifies a particular Block of data, usually associated with a single file. A Block can be uniquely identified by its filename, but each type of Block has a different set of keys which produce its unique name.

If your BlockId should be serializable, be sure to add it to the BlockId.apply() method.

Constructor Summary

Constructors

Constructor and Description
BlockId()

Method Summary

Methods

Modifier and Type	Method and Description
static scala.Product	apply(String id) Converts a BlockId "name" String back into a BlockId.
scala.Option<RDDBlockId>	asRDDId()
static scala.util.matching.Regex	BROADCAST()
boolean	equals(Object other)
int	hashCode()
boolean	isBroadcast()
boolean	isRDD()
boolean	isShuffle()
abstract String	name() A globally unique identifier for this Block.
static scala.util.matching.Regex	RDD()
static scala.util.matching.Regex	SHUFFLE_INDEX()
static scala.util.matching.Regex	SHUFFLE()
static scala.util.matching.Regex	STREAM()
static scala.util.matching.Regex	TASKRESULT()
static scala.util.matching.Regex	TEST()
String	toString()

Methods inherited from class Object

getClass, notify, notifyAll, wait, wait, wait

Constructor Detail

BlockId

public BlockId()

Method Detail

RDD

public static scala.util.matching.Regex RDD()

SHUFFLE

public static scala.util.matching.Regex SHUFFLE()

SHUFFLE_INDEX

public static scala.util.matching.Regex SHUFFLE_INDEX()

BROADCAST

public static scala.util.matching.Regex BROADCAST()

TASKRESULT

public static scala.util.matching.Regex TASKRESULT()

STREAM

public static scala.util.matching.Regex STREAM()

TEST

public static scala.util.matching.Regex TEST()

apply

public static scala.Product apply(String id)

Converts a BlockId "name" String back into a BlockId.

name

public abstract String name()

A globally unique identifier for this Block. Can be used for ser/de.

asRDDId

public scala.Option<RDDBlockId> asRDDId()

isRDD

public boolean isRDD()

isShuffle

public boolean isShuffle()

isBroadcast

public boolean isBroadcast()

toString

public String toString()

Overrides:

toString in class Object

hashCode

public int hashCode()

Overrides:

hashCode in class Object

equals

public boolean equals(Object other)

Overrides:

equals in class Object