Module org.elasticsearch.server

Package org.elasticsearch.cluster.routing.allocation.allocator

Class OrderedShardsIterator

java.lang.Object

org.elasticsearch.cluster.routing.allocation.allocator.OrderedShardsIterator

All Implemented Interfaces:

Iterator<ShardRouting>

public class OrderedShardsIterator
extends Object
implements Iterator<ShardRouting>

This class iterates all shards from all nodes. The shard order is defined by (1) allocation recency: shards from the node that had a new shard allocation would appear in the end of iteration. (2) shard priority: dictated by the provided ShardRelocationOrder.

Method Summary

Modifier and Type	Method	Description
static OrderedShardsIterator	createForBalancing(RoutingAllocation allocation, NodeAllocationOrdering ordering, ShardRelocationOrder shardRelocationOrder)	Creates an iterator over all shards in the RoutingNodes held by allocation (all shards assigned to a node) that will progress through the shards node by node based on NodeAllocationOrdering, each node's shards ordered based on the provided ShardRelocationOrder for balancing moves.
static OrderedShardsIterator	createForNecessaryMoves(RoutingAllocation allocation, NodeAllocationOrdering ordering, ShardRelocationOrder shardRelocationOrder)	Creates an iterator over all shards in the RoutingNodes held by allocation (all shards assigned to a node) that will progress through the shards node by node based on NodeAllocationOrdering, each node's shards ordered based on the provided ShardRelocationOrder for necessary moves.
void	dePrioritizeNode(String nodeId)
boolean	hasNext()
ShardRouting	next()

Methods inherited from class java.lang.Object

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

Methods inherited from interface java.util.Iterator

forEachRemaining, remove

Method Details

createForNecessaryMoves

public static OrderedShardsIterator createForNecessaryMoves(RoutingAllocation allocation,
 NodeAllocationOrdering ordering,
 ShardRelocationOrder shardRelocationOrder)

Creates an iterator over all shards in the RoutingNodes held by allocation (all shards assigned to a node) that will progress through the shards node by node based on NodeAllocationOrdering, each node's shards ordered based on the provided ShardRelocationOrder for necessary moves.

createForBalancing

public static OrderedShardsIterator createForBalancing(RoutingAllocation allocation,
 NodeAllocationOrdering ordering,
 ShardRelocationOrder shardRelocationOrder)

Creates an iterator over all shards in the RoutingNodes held by allocation (all shards assigned to a node) that will progress through the shards node by node based on NodeAllocationOrdering, each node's shards ordered based on the provided ShardRelocationOrder for balancing moves.

hasNext

public boolean hasNext()

Specified by:

hasNext in interface Iterator<ShardRouting>

next

public ShardRouting next()

Specified by:

next in interface Iterator<ShardRouting>

dePrioritizeNode

public void dePrioritizeNode(String nodeId)