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

Class HybridShuffleConfiguration.Builder

java.lang.Object

org.apache.flink.runtime.io.network.partition.hybrid.HybridShuffleConfiguration.Builder

Enclosing class:

HybridShuffleConfiguration

public static class HybridShuffleConfiguration.Builder
extends Object

Builder for HybridShuffleConfiguration.

Method Summary

Modifier and Type	Method and Description
HybridShuffleConfiguration	build()
HybridShuffleConfiguration.Builder	setBufferPoolSizeCheckIntervalMs(long bufferPoolSizeCheckIntervalMs)
HybridShuffleConfiguration.Builder	setBufferRequestTimeout(java.time.Duration bufferRequestTimeout)
HybridShuffleConfiguration.Builder	setFullStrategyNumBuffersTriggerSpillingRatio(float fullStrategyNumBuffersTriggerSpillingRatio)
HybridShuffleConfiguration.Builder	setFullStrategyReleaseBufferRatio(float fullStrategyReleaseBufferRatio)
HybridShuffleConfiguration.Builder	setFullStrategyReleaseThreshold(float fullStrategyReleaseThreshold)
HybridShuffleConfiguration.Builder	setMaxBuffersReadAhead(int maxBuffersReadAhead)
HybridShuffleConfiguration.Builder	setNumRetainedInMemoryRegionsMax(long numRetainedInMemoryRegionsMax)
HybridShuffleConfiguration.Builder	setSelectiveStrategySpillBufferRatio(float selectiveStrategySpillBufferRatio)
HybridShuffleConfiguration.Builder	setSelectiveStrategySpillThreshold(float selectiveStrategySpillThreshold)
HybridShuffleConfiguration.Builder	setSpilledIndexSegmentSize(int spilledIndexSegmentSize)
HybridShuffleConfiguration.Builder	setSpillingStrategyType(HybridShuffleConfiguration.SpillingStrategyType spillingStrategyType)

Methods inherited from class java.lang.Object

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

Method Detail

setMaxBuffersReadAhead

public HybridShuffleConfiguration.Builder setMaxBuffersReadAhead(int maxBuffersReadAhead)

setBufferRequestTimeout

public HybridShuffleConfiguration.Builder setBufferRequestTimeout(java.time.Duration bufferRequestTimeout)

setSelectiveStrategySpillThreshold

public HybridShuffleConfiguration.Builder setSelectiveStrategySpillThreshold(float selectiveStrategySpillThreshold)

setSelectiveStrategySpillBufferRatio

public HybridShuffleConfiguration.Builder setSelectiveStrategySpillBufferRatio(float selectiveStrategySpillBufferRatio)

setFullStrategyNumBuffersTriggerSpillingRatio

public HybridShuffleConfiguration.Builder setFullStrategyNumBuffersTriggerSpillingRatio(float fullStrategyNumBuffersTriggerSpillingRatio)

setFullStrategyReleaseThreshold

public HybridShuffleConfiguration.Builder setFullStrategyReleaseThreshold(float fullStrategyReleaseThreshold)

setFullStrategyReleaseBufferRatio

public HybridShuffleConfiguration.Builder setFullStrategyReleaseBufferRatio(float fullStrategyReleaseBufferRatio)

setSpillingStrategyType

public HybridShuffleConfiguration.Builder setSpillingStrategyType(HybridShuffleConfiguration.SpillingStrategyType spillingStrategyType)

setBufferPoolSizeCheckIntervalMs

public HybridShuffleConfiguration.Builder setBufferPoolSizeCheckIntervalMs(long bufferPoolSizeCheckIntervalMs)

setNumRetainedInMemoryRegionsMax

public HybridShuffleConfiguration.Builder setNumRetainedInMemoryRegionsMax(long numRetainedInMemoryRegionsMax)

setSpilledIndexSegmentSize

public HybridShuffleConfiguration.Builder setSpilledIndexSegmentSize(int spilledIndexSegmentSize)

build

public HybridShuffleConfiguration build()