Package org.elasticsearch.cluster.routing

Class RoutingNodes.UnassignedShards

org.elasticsearch.cluster.routing.RoutingNodes.UnassignedShards

All Implemented Interfaces:

<ShardRouting>

Enclosing class:

RoutingNodes

public static final class RoutingNodes.UnassignedShards
extends 
implements <ShardRouting>

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
class	RoutingNodes.UnassignedShards.UnassignedIterator

Constructor Summary

Constructors

Constructor	Description
UnassignedShards(RoutingNodes nodes)

Method Summary

Modifier and Type	Method	Description
void	add(ShardRouting shardRouting)
ShardRouting[]	drain()	Drains all unassigned shards and returns it.
int	getNumIgnoredPrimaries()	Returns the number of temporarily marked as ignored unassigned primaries
int	getNumPrimaries()	Returns the number of non-ignored unassigned primaries
<ShardRouting>	ignored()	The list of ignored unassigned shards (read only).
void	ignoreShard(ShardRouting shard, UnassignedInfo.AllocationStatus allocationStatus, RoutingChangesObserver changes)	Marks a shard as temporarily ignored and adds it to the ignore unassigned list.
boolean	isEmpty()	Returns true iff this collection contains one or more non-ignored unassigned shards.
boolean	isIgnoredEmpty()	Returns true iff any unassigned shards are marked as temporarily ignored.
RoutingNodes.UnassignedShards.UnassignedIterator	iterator()
void	shuffle()
int	size()	Returns the size of the non-ignored unassigned shards
void	<ShardRouting> comparator)

Methods inherited from class java.lang.

, , , , , , , , , ,

Methods inherited from interface java.lang.

,

Constructor Details

UnassignedShards

public UnassignedShards(RoutingNodes nodes)

Method Details

add

public void add(ShardRouting shardRouting)

sort

public void sort(<ShardRouting> comparator)

size

public int size()

Returns the size of the non-ignored unassigned shards

getNumPrimaries

public int getNumPrimaries()

Returns the number of non-ignored unassigned primaries

getNumIgnoredPrimaries

public int getNumIgnoredPrimaries()

Returns the number of temporarily marked as ignored unassigned primaries

iterator

public RoutingNodes.UnassignedShards.UnassignedIterator iterator()

Specified by:

in interface <ShardRouting>

ignored

public <ShardRouting> ignored()

The list of ignored unassigned shards (read only). The ignored unassigned shards are not part of the formal unassigned list, but are kept around and used to build back the list of unassigned shards as part of the routing table.

ignoreShard

public void ignoreShard(ShardRouting shard,
 UnassignedInfo.AllocationStatus allocationStatus,
 RoutingChangesObserver changes)

Marks a shard as temporarily ignored and adds it to the ignore unassigned list. Should be used with caution, typically, the correct usage is to removeAndIgnore from the iterator.

See Also:

ignored(), RoutingNodes.UnassignedShards.UnassignedIterator.removeAndIgnore(AllocationStatus, RoutingChangesObserver), isIgnoredEmpty()

isEmpty

public boolean isEmpty()

Returns true iff this collection contains one or more non-ignored unassigned shards.

isIgnoredEmpty

public boolean isIgnoredEmpty()

Returns true iff any unassigned shards are marked as temporarily ignored.

See Also:

ignoreShard(ShardRouting, AllocationStatus, RoutingChangesObserver), RoutingNodes.UnassignedShards.UnassignedIterator.removeAndIgnore(AllocationStatus, RoutingChangesObserver)

shuffle

public void shuffle()

drain

public ShardRouting[] drain()

Drains all unassigned shards and returns it. This method will not drain ignored shards.