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 Description static HsConsumerIdANYThis consumer id is used in the scenarios that information related to specific consumer needs to be ignored.static HsConsumerIdDEFAULTThis consumer id is used for the first consumer of a single subpartition.
-
Method Summary
All Methods Static Methods Instance Methods Concrete Methods Modifier and Type Method Description booleanequals(Object o)inthashCode()static HsConsumerIdnewId(HsConsumerId lastId)
-
-
-
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)
-
-