Package | Description |
---|---|
org.apache.flink.runtime.io.network.partition.hybrid |
Modifier and Type | Field and Description |
---|---|
static HsSpillingStrategy.Decision |
HsSpillingStrategy.Decision.NO_ACTION |
Modifier and Type | Method and Description |
---|---|
HsSpillingStrategy.Decision |
HsFullSpillingStrategy.decideActionWithGlobalInfo(HsSpillingInfoProvider spillingInfoProvider) |
HsSpillingStrategy.Decision |
HsSpillingStrategy.decideActionWithGlobalInfo(HsSpillingInfoProvider spillingInfoProvider)
Make a decision based on global information.
|
HsSpillingStrategy.Decision |
HsSelectiveSpillingStrategy.decideActionWithGlobalInfo(HsSpillingInfoProvider spillingInfoProvider) |
HsSpillingStrategy.Decision |
HsFullSpillingStrategy.onResultPartitionClosed(HsSpillingInfoProvider spillingInfoProvider) |
HsSpillingStrategy.Decision |
HsSpillingStrategy.onResultPartitionClosed(HsSpillingInfoProvider spillingInfoProvider)
Make a decision when result partition is closed.
|
HsSpillingStrategy.Decision |
HsSelectiveSpillingStrategy.onResultPartitionClosed(HsSpillingInfoProvider spillingInfoProvider) |
Modifier and Type | Method and Description |
---|---|
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) |
Optional<HsSpillingStrategy.Decision> |
HsFullSpillingStrategy.onBufferFinished(int numTotalUnSpillBuffers,
int currentPoolSize) |
Optional<HsSpillingStrategy.Decision> |
HsSpillingStrategy.onBufferFinished(int numTotalUnSpillBuffers,
int currentPoolSize)
Make a decision when a buffer becomes finished.
|
Optional<HsSpillingStrategy.Decision> |
HsSelectiveSpillingStrategy.onBufferFinished(int numTotalUnSpillBuffers,
int currentPoolSize) |
Optional<HsSpillingStrategy.Decision> |
HsFullSpillingStrategy.onMemoryUsageChanged(int numTotalRequestedBuffers,
int currentPoolSize) |
Optional<HsSpillingStrategy.Decision> |
HsSpillingStrategy.onMemoryUsageChanged(int numTotalRequestedBuffers,
int currentPoolSize)
Make a decision when memory usage is changed.
|
Optional<HsSpillingStrategy.Decision> |
HsSelectiveSpillingStrategy.onMemoryUsageChanged(int numTotalRequestedBuffers,
int currentPoolSize) |
Copyright © 2014–2023 The Apache Software Foundation. All rights reserved.