public class HsSpillingStrategyUtils extends Object
HsSpillingStrategy
.Constructor and Description |
---|
HsSpillingStrategyUtils() |
Modifier and Type | Method and Description |
---|---|
static TreeMap<Integer,List<BufferIndexAndChannel>> |
getBuffersByConsumptionPriorityInOrder(List<Integer> nextBufferIndexToConsume,
TreeMap<Integer,Deque<BufferIndexAndChannel>> subpartitionToAllBuffers,
int expectedSize)
Calculate and get expected number of buffers with the highest consumption priority.
|
public static TreeMap<Integer,List<BufferIndexAndChannel>> getBuffersByConsumptionPriorityInOrder(List<Integer> nextBufferIndexToConsume, TreeMap<Integer,Deque<BufferIndexAndChannel>> subpartitionToAllBuffers, int expectedSize)
nextBufferIndexToConsume
- downstream next buffer index to consume.subpartitionToAllBuffers
- the buffers want to compute priority, are grouped by
subpartitionId.expectedSize
- number of result buffers.Copyright © 2014–2024 The Apache Software Foundation. All rights reserved.