public class CoordinatorDynamicConfig extends Object
Modifier and Type | Class and Description |
---|---|
static class |
CoordinatorDynamicConfig.Builder |
Modifier and Type | Field and Description |
---|---|
static String |
CONFIG_KEY |
Constructor and Description |
---|
CoordinatorDynamicConfig(long millisToWaitBeforeDeleting,
long mergeBytesLimit,
int mergeSegmentsLimit,
int maxSegmentsToMove,
int replicantLifetime,
int replicationThrottleLimit,
int balancerComputeThreads,
boolean emitBalancingStats,
Object killDataSourceWhitelist,
Object killPendingSegmentsSkipList,
boolean killAllDataSources,
int maxSegmentsInNodeLoadingQueue) |
Modifier and Type | Method and Description |
---|---|
static CoordinatorDynamicConfig.Builder |
builder() |
boolean |
emitBalancingStats() |
boolean |
equals(Object o) |
int |
getBalancerComputeThreads() |
Set<String> |
getKillDataSourceWhitelist() |
Set<String> |
getKillPendingSegmentsSkipList() |
int |
getMaxSegmentsInNodeLoadingQueue() |
int |
getMaxSegmentsToMove() |
long |
getMergeBytesLimit() |
int |
getMergeSegmentsLimit() |
long |
getMillisToWaitBeforeDeleting() |
int |
getReplicantLifetime() |
int |
getReplicationThrottleLimit() |
int |
hashCode() |
boolean |
isKillAllDataSources() |
String |
toString() |
public static final String CONFIG_KEY
public CoordinatorDynamicConfig(long millisToWaitBeforeDeleting, long mergeBytesLimit, int mergeSegmentsLimit, int maxSegmentsToMove, int replicantLifetime, int replicationThrottleLimit, int balancerComputeThreads, boolean emitBalancingStats, Object killDataSourceWhitelist, Object killPendingSegmentsSkipList, boolean killAllDataSources, int maxSegmentsInNodeLoadingQueue)
public long getMillisToWaitBeforeDeleting()
public long getMergeBytesLimit()
public boolean emitBalancingStats()
public int getMergeSegmentsLimit()
public int getMaxSegmentsToMove()
public int getReplicantLifetime()
public int getReplicationThrottleLimit()
public int getBalancerComputeThreads()
public boolean isKillAllDataSources()
public int getMaxSegmentsInNodeLoadingQueue()
public static CoordinatorDynamicConfig.Builder builder()
Copyright © 2011–2018. All rights reserved.