Uses of Class
org.apache.flink.runtime.io.network.partition.hybrid.HsSpillingInfoProvider.SpillStatus

Packages that use HsSpillingInfoProvider.SpillStatus

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

Uses of HsSpillingInfoProvider.SpillStatus in org.apache.flink.runtime.io.network.partition.hybrid

Methods in org.apache.flink.runtime.io.network.partition.hybrid that return HsSpillingInfoProvider.SpillStatus

Modifier and Type	Method	Description
static HsSpillingInfoProvider.SpillStatus	HsSpillingInfoProvider.SpillStatus.valueOf(String name)	Returns the enum constant of this type with the specified name.
static HsSpillingInfoProvider.SpillStatus[]	HsSpillingInfoProvider.SpillStatus.values()	Returns an array containing the constants of this enum type, in the order they are declared.

Methods in org.apache.flink.runtime.io.network.partition.hybrid with parameters of type HsSpillingInfoProvider.SpillStatus

Modifier and Type	Method	Description
Deque<BufferIndexAndChannel>	HsMemoryDataManager.getBuffersInOrder(int subpartitionId, HsSpillingInfoProvider.SpillStatus spillStatus, HsSpillingInfoProvider.ConsumeStatusWithId consumeStatusWithId)
Deque<BufferIndexAndChannel>	HsSpillingInfoProvider.getBuffersInOrder(int subpartitionId, HsSpillingInfoProvider.SpillStatus spillStatus, HsSpillingInfoProvider.ConsumeStatusWithId consumeStatusWithId)	Get all buffers with the expected status from the subpartition.
Deque<BufferIndexAndChannel>	HsSubpartitionMemoryDataManager.getBuffersSatisfyStatus(HsSpillingInfoProvider.SpillStatus spillStatus, HsSpillingInfoProvider.ConsumeStatusWithId consumeStatusWithId)	Get buffers in HsSubpartitionMemoryDataManager.allBuffers that satisfy expected HsSpillingInfoProvider.SpillStatus and HsSpillingInfoProvider.ConsumeStatus.