Package org.elasticsearch.gateway

Class BaseGatewayShardAllocator

java.lang.Object

org.elasticsearch.gateway.BaseGatewayShardAllocator

Direct Known Subclasses:

PrimaryShardAllocator, ReplicaShardAllocator

public abstract class BaseGatewayShardAllocator
extends Object

An abstract class that implements basic functionality for allocating shards to nodes based on shard copies that already exist in the cluster. Individual implementations of this class are responsible for providing the logic to determine to which nodes (if any) those shards are allocated.

Field Summary

Fields

Modifier and Type	Field	Description
protected org.apache.logging.log4j.Logger	logger

Constructor Summary

Constructors

Constructor	Description
BaseGatewayShardAllocator()

Method Summary

Modifier and Type	Method	Description
void	allocateUnassigned(ShardRouting shardRouting, RoutingAllocation allocation, ExistingShardsAllocator.UnassignedAllocationHandler unassignedAllocationHandler)	Allocate an unassigned shard to nodes (if any) where valid copies of the shard already exist.
protected static List<NodeAllocationResult>	buildDecisionsForAllNodes(ShardRouting shard, RoutingAllocation allocation)	Builds decisions for all nodes in the cluster, so that the explain API can provide information on allocation decisions for each node, while still waiting to allocate the shard (e.g.
protected long	getExpectedShardSize(ShardRouting shardRouting, RoutingAllocation allocation)
abstract AllocateUnassignedDecision	makeAllocationDecision(ShardRouting unassignedShard, RoutingAllocation allocation, org.apache.logging.log4j.Logger logger)	Make a decision on the allocation of an unassigned shard.

Methods inherited from class java.lang.Object

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

Field Details

logger

protected final org.apache.logging.log4j.Logger logger

Constructor Details

BaseGatewayShardAllocator

public BaseGatewayShardAllocator()

Method Details

allocateUnassigned

public void allocateUnassigned(ShardRouting shardRouting,
 RoutingAllocation allocation,
 ExistingShardsAllocator.UnassignedAllocationHandler unassignedAllocationHandler)

Allocate an unassigned shard to nodes (if any) where valid copies of the shard already exist. It is up to the individual implementations of makeAllocationDecision(ShardRouting, RoutingAllocation, Logger) to make decisions on assigning shards to nodes.

Parameters:

shardRouting - the shard to allocate

allocation - the allocation state container object

unassignedAllocationHandler - handles the allocation of the current shard

getExpectedShardSize

protected long getExpectedShardSize(ShardRouting shardRouting,
 RoutingAllocation allocation)

makeAllocationDecision

public abstract AllocateUnassignedDecision makeAllocationDecision(ShardRouting unassignedShard,
 RoutingAllocation allocation,
 org.apache.logging.log4j.Logger logger)

Make a decision on the allocation of an unassigned shard. This method is used by allocateUnassigned(ShardRouting, RoutingAllocation, ExistingShardsAllocator.UnassignedAllocationHandler) to make decisions about whether or not the shard can be allocated by this allocator and if so, to which node it will be allocated.

Parameters:

unassignedShard - the unassigned shard to allocate

allocation - the current routing state

logger - the logger

Returns:

an AllocateUnassignedDecision with the final decision of whether to allocate and details of the decision

buildDecisionsForAllNodes

protected static List<NodeAllocationResult> buildDecisionsForAllNodes(ShardRouting shard,
 RoutingAllocation allocation)

Builds decisions for all nodes in the cluster, so that the explain API can provide information on allocation decisions for each node, while still waiting to allocate the shard (e.g. due to fetching shard data).