Package org.elasticsearch.cluster.routing.allocation.decider

Class ConcurrentRebalanceAllocationDecider

java.lang.Object

org.elasticsearch.common.component.AbstractComponent

org.elasticsearch.cluster.routing.allocation.decider.AllocationDecider

org.elasticsearch.cluster.routing.allocation.decider.ConcurrentRebalanceAllocationDecider

public class ConcurrentRebalanceAllocationDecider
extends AllocationDecider

Similar to the ClusterRebalanceAllocationDecider this AllocationDecider controls the number of currently in-progress re-balance (relocation) operations and restricts node allocations if the configured threshold is reached. The default number of concurrent rebalance operations is set to 2

Re-balance operations can be controlled in real-time via the cluster update API using cluster.routing.allocation.cluster_concurrent_rebalance. Iff this setting is set to -1 the number of concurrent re-balance operations are unlimited.

Field Summary

Fields

Modifier and Type	Field	Description
static Setting<java.lang.Integer>	CLUSTER_ROUTING_ALLOCATION_CLUSTER_CONCURRENT_REBALANCE_SETTING
static java.lang.String	NAME

Fields inherited from class org.elasticsearch.common.component.AbstractComponent

deprecationLogger, logger, settings

Constructor Summary

Constructors

Constructor	Description
ConcurrentRebalanceAllocationDecider(Settings settings, ClusterSettings clusterSettings)

Method Summary

Modifier and Type	Method	Description
Decision	canRebalance(ShardRouting shardRouting, RoutingAllocation allocation)	Returns a Decision whether the given shard routing can be re-balanced to the given allocation.

Methods inherited from class org.elasticsearch.common.component.AbstractComponent

logDeprecatedSetting, logRemovedSetting, nodeName

Methods inherited from class org.elasticsearch.cluster.routing.allocation.decider.AllocationDecider

canAllocate, canAllocate, canAllocate, canAllocate, canForceAllocatePrimary, canRebalance, canRemain

Methods inherited from class java.lang.Object

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

Field Detail

NAME

public static final java.lang.String NAME

See Also:

Constant Field Values

CLUSTER_ROUTING_ALLOCATION_CLUSTER_CONCURRENT_REBALANCE_SETTING

public static final Setting<java.lang.Integer> CLUSTER_ROUTING_ALLOCATION_CLUSTER_CONCURRENT_REBALANCE_SETTING

Constructor Detail

ConcurrentRebalanceAllocationDecider

public ConcurrentRebalanceAllocationDecider(Settings settings,
                                            ClusterSettings clusterSettings)

Method Detail

canRebalance

public Decision canRebalance(ShardRouting shardRouting,
                             RoutingAllocation allocation)

Description copied from class: AllocationDecider

Returns a Decision whether the given shard routing can be re-balanced to the given allocation. The default is Decision.ALWAYS.

Overrides:

canRebalance in class AllocationDecider