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

Packages that use HsSpillingStrategy.Decision

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

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

Fields in org.apache.flink.runtime.io.network.partition.hybrid declared as HsSpillingStrategy.Decision

Modifier and Type	Field	Description
static HsSpillingStrategy.Decision	HsSpillingStrategy.Decision.NO_ACTION

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

Modifier and Type	Method	Description
HsSpillingStrategy.Decision	HsFullSpillingStrategy.decideActionWithGlobalInfo(HsSpillingInfoProvider spillingInfoProvider)
HsSpillingStrategy.Decision	HsSelectiveSpillingStrategy.decideActionWithGlobalInfo(HsSpillingInfoProvider spillingInfoProvider)
HsSpillingStrategy.Decision	HsSpillingStrategy.decideActionWithGlobalInfo(HsSpillingInfoProvider spillingInfoProvider)	Make a decision based on global information.
HsSpillingStrategy.Decision	HsFullSpillingStrategy.onResultPartitionClosed(HsSpillingInfoProvider spillingInfoProvider)
HsSpillingStrategy.Decision	HsSelectiveSpillingStrategy.onResultPartitionClosed(HsSpillingInfoProvider spillingInfoProvider)
HsSpillingStrategy.Decision	HsSpillingStrategy.onResultPartitionClosed(HsSpillingInfoProvider spillingInfoProvider)	Make a decision when result partition is closed.

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

Modifier and Type	Method	Description
Optional<HsSpillingStrategy.Decision>	HsFullSpillingStrategy.onBufferConsumed(BufferIndexAndChannel consumedBuffer)
Optional<HsSpillingStrategy.Decision>	HsSelectiveSpillingStrategy.onBufferConsumed(BufferIndexAndChannel consumedBuffer)
Optional<HsSpillingStrategy.Decision>	HsSpillingStrategy.onBufferConsumed(BufferIndexAndChannel consumedBuffer)	Make a decision when a buffer is consumed.
Optional<HsSpillingStrategy.Decision>	HsFullSpillingStrategy.onBufferFinished(int numTotalUnSpillBuffers, int currentPoolSize)
Optional<HsSpillingStrategy.Decision>	HsSelectiveSpillingStrategy.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>	HsFullSpillingStrategy.onMemoryUsageChanged(int numTotalRequestedBuffers, int currentPoolSize)
Optional<HsSpillingStrategy.Decision>	HsSelectiveSpillingStrategy.onMemoryUsageChanged(int numTotalRequestedBuffers, int currentPoolSize)
Optional<HsSpillingStrategy.Decision>	HsSpillingStrategy.onMemoryUsageChanged(int numTotalRequestedBuffers, int currentPoolSize)	Make a decision when memory usage is changed.