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

Class TieredStorageConfiguration.Builder

java.lang.Object

org.apache.flink.runtime.io.network.partition.hybrid.tiered.common.TieredStorageConfiguration.Builder

Enclosing class:

TieredStorageConfiguration

public static class TieredStorageConfiguration.Builder
extends Object

The builder for TieredStorageConfiguration.

Constructor Summary

Constructors

Constructor	Description
Builder()

Method Summary

Modifier and Type	Method	Description
TieredStorageConfiguration	build()
TieredStorageConfiguration.Builder	setDiskTierBufferRequestTimeout(java.time.Duration diskTierBufferRequestTimeout)
TieredStorageConfiguration.Builder	setDiskTierExclusiveBuffers(int diskTierExclusiveBuffers)
TieredStorageConfiguration.Builder	setDiskTierMaxBuffersReadAhead(int diskTierMaxBuffersReadAhead)
TieredStorageConfiguration.Builder	setDiskTierNumBytesPerSegment(int diskTierNumBytesPerSegment)
TieredStorageConfiguration.Builder	setMaxCachedBytesBeforeFlush(int maxCachedBytesBeforeFlush)
TieredStorageConfiguration.Builder	setMemoryTierExclusiveBuffers(int memoryTierExclusiveBuffers)
TieredStorageConfiguration.Builder	setMemoryTierNumBytesPerSegment(int memoryTierNumBytesPerSegment)
TieredStorageConfiguration.Builder	setMemoryTierSubpartitionMaxQueuedBuffers(int memoryTierSubpartitionMaxQueuedBuffers)
TieredStorageConfiguration.Builder	setMinReserveDiskSpaceFraction(float minReserveDiskSpaceFraction)
TieredStorageConfiguration.Builder	setNumBuffersTriggerFlushRatio(float numBuffersTriggerFlushRatio)
TieredStorageConfiguration.Builder	setNumBuffersUseSortAccumulatorThreshold(int numBuffersUseSortAccumulatorThreshold)
TieredStorageConfiguration.Builder	setNumRetainedInMemoryRegionsMax(long numRetainedInMemoryRegionsMax)
TieredStorageConfiguration.Builder	setRegionGroupSizeInBytes(int regionGroupSizeInBytes)
TieredStorageConfiguration.Builder	setRemoteStorageBasePath(String remoteStorageBasePath)
TieredStorageConfiguration.Builder	setRemoteTierExclusiveBuffers(int remoteTierExclusiveBuffers)
TieredStorageConfiguration.Builder	setRemoteTierNumBytesPerSegment(int remoteTierNumBytesPerSegment)
TieredStorageConfiguration.Builder	setTieredStorageBufferSize(int tieredStorageBufferSize)

Methods inherited from class java.lang.Object

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

Constructor Detail

Builder

public Builder()

Method Detail

setRemoteStorageBasePath

public TieredStorageConfiguration.Builder setRemoteStorageBasePath(String remoteStorageBasePath)

setTieredStorageBufferSize

public TieredStorageConfiguration.Builder setTieredStorageBufferSize(int tieredStorageBufferSize)

setMemoryTierExclusiveBuffers

public TieredStorageConfiguration.Builder setMemoryTierExclusiveBuffers(int memoryTierExclusiveBuffers)

setDiskTierExclusiveBuffers

public TieredStorageConfiguration.Builder setDiskTierExclusiveBuffers(int diskTierExclusiveBuffers)

setRemoteTierExclusiveBuffers

public TieredStorageConfiguration.Builder setRemoteTierExclusiveBuffers(int remoteTierExclusiveBuffers)

setNumBuffersUseSortAccumulatorThreshold

public TieredStorageConfiguration.Builder setNumBuffersUseSortAccumulatorThreshold(int numBuffersUseSortAccumulatorThreshold)

setMemoryTierNumBytesPerSegment

public TieredStorageConfiguration.Builder setMemoryTierNumBytesPerSegment(int memoryTierNumBytesPerSegment)

setDiskTierNumBytesPerSegment

public TieredStorageConfiguration.Builder setDiskTierNumBytesPerSegment(int diskTierNumBytesPerSegment)

setRemoteTierNumBytesPerSegment

public TieredStorageConfiguration.Builder setRemoteTierNumBytesPerSegment(int remoteTierNumBytesPerSegment)

setMemoryTierSubpartitionMaxQueuedBuffers

public TieredStorageConfiguration.Builder setMemoryTierSubpartitionMaxQueuedBuffers(int memoryTierSubpartitionMaxQueuedBuffers)

setNumBuffersTriggerFlushRatio

public TieredStorageConfiguration.Builder setNumBuffersTriggerFlushRatio(float numBuffersTriggerFlushRatio)

setDiskTierMaxBuffersReadAhead

public TieredStorageConfiguration.Builder setDiskTierMaxBuffersReadAhead(int diskTierMaxBuffersReadAhead)

setDiskTierBufferRequestTimeout

public TieredStorageConfiguration.Builder setDiskTierBufferRequestTimeout(java.time.Duration diskTierBufferRequestTimeout)

setMinReserveDiskSpaceFraction

public TieredStorageConfiguration.Builder setMinReserveDiskSpaceFraction(float minReserveDiskSpaceFraction)

setRegionGroupSizeInBytes

public TieredStorageConfiguration.Builder setRegionGroupSizeInBytes(int regionGroupSizeInBytes)

setNumRetainedInMemoryRegionsMax

public TieredStorageConfiguration.Builder setNumRetainedInMemoryRegionsMax(long numRetainedInMemoryRegionsMax)

setMaxCachedBytesBeforeFlush

public TieredStorageConfiguration.Builder setMaxCachedBytesBeforeFlush(int maxCachedBytesBeforeFlush)

build

public TieredStorageConfiguration build()