org.apache.flink.runtime.io.network.partition

Class ResultPartitionID

java.lang.Object

org.apache.flink.runtime.io.network.partition.ResultPartitionID

All Implemented Interfaces:

Serializable

public final class ResultPartitionID
extends Object
implements Serializable

Runtime identifier of a produced IntermediateResultPartition.

In failure cases the IntermediateResultPartitionID is not enough to uniquely identify a result partition. It needs to be associated with the producing task as well to ensure correct tracking of failed/restarted tasks.

See Also:

Serialized Form

Constructor Summary

Constructors

Constructor and Description
ResultPartitionID()
ResultPartitionID(byte[] bytes)
ResultPartitionID(IntermediateResultPartitionID partitionId, ExecutionAttemptID producerId)

Method Summary

Modifier and Type	Method and Description
boolean	equals(Object obj)
byte[]	getBytes()
IntermediateResultPartitionID	getPartitionId()
ExecutionAttemptID	getProducerId()
int	hashCode()
String	toString()

Methods inherited from class java.lang.Object

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

Constructor Detail

ResultPartitionID

@VisibleForTesting
public ResultPartitionID()

ResultPartitionID

public ResultPartitionID(IntermediateResultPartitionID partitionId,
                         ExecutionAttemptID producerId)

ResultPartitionID

public ResultPartitionID(byte[] bytes)

Method Detail

getPartitionId

public IntermediateResultPartitionID getPartitionId()

getProducerId

public ExecutionAttemptID getProducerId()

equals

public boolean equals(Object obj)

Overrides:

equals in class Object

hashCode

public int hashCode()

Overrides:

hashCode in class Object

toString

public String toString()

Overrides:

toString in class Object

getBytes

public byte[] getBytes()