Package | Description |
---|---|
org.apache.flink.runtime.io.network.partition.hybrid |
Modifier and Type | Method and Description |
---|---|
BufferIndexAndChannel |
HsBufferContext.getBufferIndexAndChannel() |
Modifier and Type | Method and Description |
---|---|
void |
HsMemoryDataManagerOperation.onBufferConsumed(BufferIndexAndChannel consumedBuffer)
This method is called when buffer is consumed.
|
Optional<HsSpillingStrategy.Decision> |
HsFullSpillingStrategy.onBufferConsumed(BufferIndexAndChannel consumedBuffer) |
Optional<HsSpillingStrategy.Decision> |
HsSpillingStrategy.onBufferConsumed(BufferIndexAndChannel consumedBuffer)
Make a decision when a buffer is consumed.
|
Optional<HsSpillingStrategy.Decision> |
HsSelectiveSpillingStrategy.onBufferConsumed(BufferIndexAndChannel consumedBuffer) |
void |
HsMemoryDataManager.onBufferConsumed(BufferIndexAndChannel consumedBuffer) |
Modifier and Type | Method and 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.
|
Copyright © 2014–2023 The Apache Software Foundation. All rights reserved.