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

Packages that use BufferIndexAndChannel

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

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

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

Modifier and Type	Method	Description
BufferIndexAndChannel	HsBufferContext.getBufferIndexAndChannel()

Methods in org.apache.flink.runtime.io.network.partition.hybrid that return types with arguments of type BufferIndexAndChannel

Modifier and Type	Method	Description
static TreeMap<Integer,List<BufferIndexAndChannel>>	HsSpillingStrategyUtils.getBuffersByConsumptionPriorityInOrder(List<Integer> nextBufferIndexToConsume, TreeMap<Integer,Deque<BufferIndexAndChannel>> subpartitionToAllBuffers, int expectedSize)	Calculate and get expected number of buffers with the highest consumption priority.
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.
Map<Integer,List<BufferIndexAndChannel>>	HsSpillingStrategy.Decision.getBufferToRelease()
Map<Integer,List<BufferIndexAndChannel>>	HsSpillingStrategy.Decision.getBufferToSpill()

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

Modifier and Type	Method	Description
Optional<HsSpillingStrategy.Decision>	HsFullSpillingStrategy.onBufferConsumed(BufferIndexAndChannel consumedBuffer)
void	HsMemoryDataManager.onBufferConsumed(BufferIndexAndChannel consumedBuffer)
void	HsMemoryDataManagerOperation.onBufferConsumed(BufferIndexAndChannel consumedBuffer)	This method is called when buffer is consumed.
Optional<HsSpillingStrategy.Decision>	HsSelectiveSpillingStrategy.onBufferConsumed(BufferIndexAndChannel consumedBuffer)
Optional<HsSpillingStrategy.Decision>	HsSpillingStrategy.onBufferConsumed(BufferIndexAndChannel consumedBuffer)	Make a decision when a buffer is consumed.

Method parameters in org.apache.flink.runtime.io.network.partition.hybrid with type arguments of type BufferIndexAndChannel

Modifier and Type	Method	Description
static TreeMap<Integer,List<BufferIndexAndChannel>>	HsSpillingStrategyUtils.getBuffersByConsumptionPriorityInOrder(List<Integer> nextBufferIndexToConsume, TreeMap<Integer,Deque<BufferIndexAndChannel>> subpartitionToAllBuffers, int expectedSize)	Calculate and get expected number of buffers with the highest consumption priority.
void	HsSubpartitionMemoryDataManager.releaseSubpartitionBuffers(List<BufferIndexAndChannel> toRelease)	Release this subpartition's buffers in a decision.
List<BufferWithIdentity>	HsSubpartitionMemoryDataManager.spillSubpartitionBuffers(List<BufferIndexAndChannel> toSpill, CompletableFuture<Void> spillDoneFuture)	Spill this subpartition's buffers in a decision.