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

Class HsSpillingInfoProvider.ConsumeStatusWithId

java.lang.Object

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

Enclosing interface:

HsSpillingInfoProvider

public static class HsSpillingInfoProvider.ConsumeStatusWithId
extends Object

This class represents a pair of HsSpillingInfoProvider.ConsumeStatus and consumer id.

Field Summary

Fields

Modifier and Type	Field	Description
static HsSpillingInfoProvider.ConsumeStatusWithId	ALL_ANY

Method Summary

Modifier and Type	Method	Description
static HsSpillingInfoProvider.ConsumeStatusWithId	fromStatusAndConsumerId(HsSpillingInfoProvider.ConsumeStatus consumeStatus, HsConsumerId consumerId)

Methods inherited from class java.lang.Object

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

Field Detail

ALL_ANY

public static final HsSpillingInfoProvider.ConsumeStatusWithId ALL_ANY

Method Detail

fromStatusAndConsumerId

public static HsSpillingInfoProvider.ConsumeStatusWithId fromStatusAndConsumerId(HsSpillingInfoProvider.ConsumeStatus consumeStatus,
                                                                                 HsConsumerId consumerId)