io.druid.server.coordinator

Class CoordinatorDynamicConfig

java.lang.Object

io.druid.server.coordinator.CoordinatorDynamicConfig

public class CoordinatorDynamicConfig
extends Object

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static class	CoordinatorDynamicConfig.Builder

Field Summary

Fields

Modifier and Type	Field and Description
static String	CONFIG_KEY

Constructor Summary

Constructors

Constructor and Description
CoordinatorDynamicConfig(long millisToWaitBeforeDeleting, long mergeBytesLimit, int mergeSegmentsLimit, int maxSegmentsToMove, int replicantLifetime, int replicationThrottleLimit, int balancerComputeThreads, boolean emitBalancingStats, Object killDataSourceWhitelist, boolean killAllDataSources)

Method Summary

Modifier and Type	Method and Description
boolean	emitBalancingStats()
boolean	equals(Object o)
int	getBalancerComputeThreads()
Set<String>	getKillDataSourceWhitelist()
int	getMaxSegmentsToMove()
long	getMergeBytesLimit()
int	getMergeSegmentsLimit()
long	getMillisToWaitBeforeDeleting()
int	getReplicantLifetime()
int	getReplicationThrottleLimit()
int	hashCode()
boolean	isKillAllDataSources()
String	toString()

Methods inherited from class java.lang.Object

clone, finalize, getClass, notify, notifyAll, wait, wait, wait

Field Detail

CONFIG_KEY

public static final String CONFIG_KEY

See Also:

Constant Field Values

Constructor Detail

CoordinatorDynamicConfig

public CoordinatorDynamicConfig(long millisToWaitBeforeDeleting,
                                long mergeBytesLimit,
                                int mergeSegmentsLimit,
                                int maxSegmentsToMove,
                                int replicantLifetime,
                                int replicationThrottleLimit,
                                int balancerComputeThreads,
                                boolean emitBalancingStats,
                                Object killDataSourceWhitelist,
                                boolean killAllDataSources)

Method Detail

getMillisToWaitBeforeDeleting

public long getMillisToWaitBeforeDeleting()

getMergeBytesLimit

public long getMergeBytesLimit()

emitBalancingStats

public boolean emitBalancingStats()

getMergeSegmentsLimit

public int getMergeSegmentsLimit()

getMaxSegmentsToMove

public int getMaxSegmentsToMove()

getReplicantLifetime

public int getReplicantLifetime()

getReplicationThrottleLimit

public int getReplicationThrottleLimit()

getBalancerComputeThreads

public int getBalancerComputeThreads()

getKillDataSourceWhitelist

public Set<String> getKillDataSourceWhitelist()

isKillAllDataSources

public boolean isKillAllDataSources()

toString

public String toString()

Overrides:

toString in class Object

equals

public boolean equals(Object o)

Overrides:

equals in class Object

hashCode

public int hashCode()

Overrides:

hashCode in class Object