org.elasticsearch.cluster.routing.allocation

Class AllocationService

java.lang.Object

org.elasticsearch.common.component.AbstractComponent

org.elasticsearch.cluster.routing.allocation.AllocationService

public class AllocationService
extends AbstractComponent

This service manages the node allocation of a cluster. For this reason the AllocationService keeps AllocationDeciders to choose nodes for shard allocation. This class also manages new nodes joining the cluster and rerouting of shards.

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static class	AllocationService.CommandsResult this class is used to describe results of applying a set of AllocationCommand

Field Summary

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

deprecationLogger, logger, settings

Constructor Summary

Constructors

Constructor and Description
AllocationService(Settings settings, AllocationDeciders allocationDeciders, GatewayAllocator gatewayAllocator, ShardsAllocator shardsAllocator, ClusterInfoService clusterInfoService)

Method Summary

Modifier and Type	Method and Description
ClusterState	applyFailedShard(ClusterState clusterState, ShardRouting failedShard)
ClusterState	applyFailedShards(ClusterState clusterState, java.util.List<FailedShard> failedShards)
ClusterState	applyFailedShards(ClusterState clusterState, java.util.List<FailedShard> failedShards, java.util.List<StaleShard> staleShards) Applies the failed shards.
ClusterState	applyStartedShards(ClusterState clusterState, java.util.List<ShardRouting> startedShards) Applies the started shards.
protected ClusterState	buildResultAndLogHealthChange(ClusterState oldState, RoutingAllocation allocation, java.lang.String reason)
protected long	currentNanoTime() override this to control time based decisions during allocation
ClusterState	deassociateDeadNodes(ClusterState clusterState, boolean reroute, java.lang.String reason) unassigned an shards that are associated with nodes that are no longer part of the cluster, potentially promoting replicas if needed.
AllocationService.CommandsResult	reroute(ClusterState clusterState, AllocationCommands commands, boolean explain, boolean retryFailed)
ClusterState	reroute(ClusterState clusterState, java.lang.String reason) Reroutes the routing table based on the live nodes.
protected ClusterState	reroute(ClusterState clusterState, java.lang.String reason, boolean debug) Reroutes the routing table based on the live nodes.

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

logDeprecatedSetting, logRemovedSetting, nodeName

Methods inherited from class java.lang.Object

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

Constructor Detail

AllocationService

@Inject
public AllocationService(Settings settings,
                                 AllocationDeciders allocationDeciders,
                                 GatewayAllocator gatewayAllocator,
                                 ShardsAllocator shardsAllocator,
                                 ClusterInfoService clusterInfoService)

Method Detail

applyStartedShards

public ClusterState applyStartedShards(ClusterState clusterState,
                                       java.util.List<ShardRouting> startedShards)

Applies the started shards. Note, only initializing ShardRouting instances that exist in the routing table should be provided as parameter and no duplicates should be contained.

If the same instance of the ClusterState is returned, then no change has been made.

buildResultAndLogHealthChange

protected ClusterState buildResultAndLogHealthChange(ClusterState oldState,
                                                     RoutingAllocation allocation,
                                                     java.lang.String reason)

applyFailedShard

public ClusterState applyFailedShard(ClusterState clusterState,
                                     ShardRouting failedShard)

applyFailedShards

public ClusterState applyFailedShards(ClusterState clusterState,
                                      java.util.List<FailedShard> failedShards)

applyFailedShards

public ClusterState applyFailedShards(ClusterState clusterState,
                                      java.util.List<FailedShard> failedShards,
                                      java.util.List<StaleShard> staleShards)

Applies the failed shards. Note, only assigned ShardRouting instances that exist in the routing table should be provided as parameter. Also applies a list of allocation ids to remove from the in-sync set for shard copies for which there are no routing entries in the routing table.

If the same instance of ClusterState is returned, then no change has been made.

deassociateDeadNodes

public ClusterState deassociateDeadNodes(ClusterState clusterState,
                                         boolean reroute,
                                         java.lang.String reason)

unassigned an shards that are associated with nodes that are no longer part of the cluster, potentially promoting replicas if needed.

reroute

public AllocationService.CommandsResult reroute(ClusterState clusterState,
                                                AllocationCommands commands,
                                                boolean explain,
                                                boolean retryFailed)

reroute

public ClusterState reroute(ClusterState clusterState,
                            java.lang.String reason)

Reroutes the routing table based on the live nodes.

If the same instance of ClusterState is returned, then no change has been made.

reroute

protected ClusterState reroute(ClusterState clusterState,
                               java.lang.String reason,
                               boolean debug)

Reroutes the routing table based on the live nodes.

If the same instance of ClusterState is returned, then no change has been made.

currentNanoTime

protected long currentNanoTime()

override this to control time based decisions during allocation