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 forHybridShuffleConfiguration.
-
-
Method Summary
-
-
-
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)
-
setRegionGroupSizeInBytes
public HybridShuffleConfiguration.Builder setRegionGroupSizeInBytes(int regionGroupSizeInBytes)
-
build
public HybridShuffleConfiguration build()
-
-