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

Packages that use HsSpillingInfoProvider.ConsumeStatusWithId

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

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

Fields in org.apache.flink.runtime.io.network.partition.hybrid declared as HsSpillingInfoProvider.ConsumeStatusWithId

Modifier and Type	Field	Description
static HsSpillingInfoProvider.ConsumeStatusWithId	HsSpillingInfoProvider.ConsumeStatusWithId.ALL_ANY

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

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

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

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.