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

Class HsSpillingStrategy.Decision

java.lang.Object

org.apache.flink.runtime.io.network.partition.hybrid.HsSpillingStrategy.Decision

Enclosing interface:

HsSpillingStrategy

public static class HsSpillingStrategy.Decision
extends Object

This class represents the spill and release decision made by HsSpillingStrategy, in other words, which data is to be spilled and which data is to be released.

Field Summary

Fields

Modifier and Type	Field	Description
static HsSpillingStrategy.Decision	NO_ACTION

Method Summary

Modifier and Type	Method	Description
static org.apache.flink.runtime.io.network.partition.hybrid.HsSpillingStrategy.Decision.Builder	builder()
Map<Integer,List<BufferIndexAndChannel>>	getBufferToRelease()
Map<Integer,List<BufferIndexAndChannel>>	getBufferToSpill()

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Field Detail

NO_ACTION

public static final HsSpillingStrategy.Decision NO_ACTION

Method Detail

getBufferToSpill

public Map<Integer,List<BufferIndexAndChannel>> getBufferToSpill()

getBufferToRelease

public Map<Integer,List<BufferIndexAndChannel>> getBufferToRelease()

builder

public static org.apache.flink.runtime.io.network.partition.hybrid.HsSpillingStrategy.Decision.Builder builder()