org.apache.druid.server.coordinator

Class CoordinatorDynamicConfig.Builder

java.lang.Object

org.apache.druid.server.coordinator.CoordinatorDynamicConfig.Builder

Enclosing class:

CoordinatorDynamicConfig

public static class CoordinatorDynamicConfig.Builder
extends Object

Constructor Summary

Constructors

Constructor and Description
Builder()
Builder(Long millisToWaitBeforeDeleting, Long mergeBytesLimit, Integer mergeSegmentsLimit, Integer maxSegmentsToMove, Integer replicantLifetime, Integer replicationThrottleLimit, Integer balancerComputeThreads, Boolean emitBalancingStats, Object killDataSourceWhitelist, Boolean killAllDataSources, Object killPendingSegmentsSkipList, Integer maxSegmentsInNodeLoadingQueue)

Method Summary

Modifier and Type	Method and Description
CoordinatorDynamicConfig	build()
CoordinatorDynamicConfig	build(CoordinatorDynamicConfig defaults)
CoordinatorDynamicConfig.Builder	withBalancerComputeThreads(int balancerComputeThreads)
CoordinatorDynamicConfig.Builder	withEmitBalancingStats(boolean emitBalancingStats)
CoordinatorDynamicConfig.Builder	withKillAllDataSources(boolean killAllDataSources)
CoordinatorDynamicConfig.Builder	withKillDataSourceWhitelist(Set<String> killDataSourceWhitelist)
CoordinatorDynamicConfig.Builder	withMaxSegmentsInNodeLoadingQueue(int maxSegmentsInNodeLoadingQueue)
CoordinatorDynamicConfig.Builder	withMaxSegmentsToMove(int maxSegmentsToMove)
CoordinatorDynamicConfig.Builder	withMergeBytesLimit(long mergeBytesLimit)
CoordinatorDynamicConfig.Builder	withMergeSegmentsLimit(int mergeSegmentsLimit)
CoordinatorDynamicConfig.Builder	withMillisToWaitBeforeDeleting(long millisToWaitBeforeDeleting)
CoordinatorDynamicConfig.Builder	withReplicantLifetime(int replicantLifetime)
CoordinatorDynamicConfig.Builder	withReplicationThrottleLimit(int replicationThrottleLimit)

Methods inherited from class java.lang.Object

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

Constructor Detail

Builder

public Builder()

Builder

public Builder(@Nullable
               Long millisToWaitBeforeDeleting,
               @Nullable
               Long mergeBytesLimit,
               @Nullable
               Integer mergeSegmentsLimit,
               @Nullable
               Integer maxSegmentsToMove,
               @Nullable
               Integer replicantLifetime,
               @Nullable
               Integer replicationThrottleLimit,
               @Nullable
               Integer balancerComputeThreads,
               @Nullable
               Boolean emitBalancingStats,
               @Nullable
               Object killDataSourceWhitelist,
               @Nullable
               Boolean killAllDataSources,
               @Nullable
               Object killPendingSegmentsSkipList,
               @Nullable
               Integer maxSegmentsInNodeLoadingQueue)

Method Detail

withMillisToWaitBeforeDeleting

public CoordinatorDynamicConfig.Builder withMillisToWaitBeforeDeleting(long millisToWaitBeforeDeleting)

withMergeBytesLimit

public CoordinatorDynamicConfig.Builder withMergeBytesLimit(long mergeBytesLimit)

withMergeSegmentsLimit

public CoordinatorDynamicConfig.Builder withMergeSegmentsLimit(int mergeSegmentsLimit)

withMaxSegmentsToMove

public CoordinatorDynamicConfig.Builder withMaxSegmentsToMove(int maxSegmentsToMove)

withReplicantLifetime

public CoordinatorDynamicConfig.Builder withReplicantLifetime(int replicantLifetime)

withReplicationThrottleLimit

public CoordinatorDynamicConfig.Builder withReplicationThrottleLimit(int replicationThrottleLimit)

withBalancerComputeThreads

public CoordinatorDynamicConfig.Builder withBalancerComputeThreads(int balancerComputeThreads)

withEmitBalancingStats

public CoordinatorDynamicConfig.Builder withEmitBalancingStats(boolean emitBalancingStats)

withKillDataSourceWhitelist

public CoordinatorDynamicConfig.Builder withKillDataSourceWhitelist(Set<String> killDataSourceWhitelist)

withKillAllDataSources

public CoordinatorDynamicConfig.Builder withKillAllDataSources(boolean killAllDataSources)

withMaxSegmentsInNodeLoadingQueue

public CoordinatorDynamicConfig.Builder withMaxSegmentsInNodeLoadingQueue(int maxSegmentsInNodeLoadingQueue)

build

public CoordinatorDynamicConfig build()

build

public CoordinatorDynamicConfig build(CoordinatorDynamicConfig defaults)