public class ShufflePushBlockId extends BlockId implements scala.Product, scala.Serializable
Constructor and Description |
---|
ShufflePushBlockId(int shuffleId,
int shuffleMergeId,
int mapIndex,
int reduceId) |
Modifier and Type | Method and Description |
---|---|
abstract static R |
apply(T1 v1,
T2 v2,
T3 v3,
T4 v4) |
int |
mapIndex() |
String |
name()
A globally unique identifier for this Block.
|
int |
reduceId() |
int |
shuffleId() |
int |
shuffleMergeId() |
static String |
toString() |
apply, asRDDId, BROADCAST, isBroadcast, isRDD, isShuffle, isShuffleChunk, RDD, SHUFFLE_BATCH, SHUFFLE_CHUNK, SHUFFLE_DATA, SHUFFLE_INDEX, SHUFFLE_MERGED_DATA, SHUFFLE_MERGED_INDEX, SHUFFLE_MERGED_META, SHUFFLE_MERGED, SHUFFLE_PUSH, SHUFFLE, STREAM, TASKRESULT, TEMP_LOCAL, TEMP_SHUFFLE, TEST, toString
public ShufflePushBlockId(int shuffleId, int shuffleMergeId, int mapIndex, int reduceId)