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

Class HsConsumerId

java.lang.Object

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

public class HsConsumerId
extends Object

This class represents the identifier of hybrid shuffle's consumer.

Field Summary

Fields

Modifier and Type	Field and Description
static HsConsumerId	ANY This consumer id is used in the scenarios that information related to specific consumer needs to be ignored.
static HsConsumerId	DEFAULT This consumer id is used for the first consumer of a single subpartition.

Method Summary

Modifier and Type	Method and Description
boolean	equals(Object o)
int	hashCode()
static HsConsumerId	newId(HsConsumerId lastId)

Methods inherited from class java.lang.Object

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

Field Detail

ANY

public static final HsConsumerId ANY

This consumer id is used in the scenarios that information related to specific consumer needs to be ignored.

DEFAULT

public static final HsConsumerId DEFAULT

This consumer id is used for the first consumer of a single subpartition.

Method Detail

newId

public static HsConsumerId newId(@Nullable
                                 HsConsumerId lastId)

equals

public boolean equals(Object o)

Overrides:

equals in class Object

hashCode

public int hashCode()

Overrides:

hashCode in class Object