Package org.elasticsearch.cluster.routing

Class IndexRoutingTable

java.lang.Object

org.elasticsearch.cluster.AbstractDiffable<IndexRoutingTable>

org.elasticsearch.cluster.routing.IndexRoutingTable

All Implemented Interfaces:

Iterable<IndexShardRoutingTable>, Diffable<IndexRoutingTable>, Writeable

public class IndexRoutingTable
extends AbstractDiffable<IndexRoutingTable>
implements Iterable<IndexShardRoutingTable>

The IndexRoutingTable represents routing information for a single index. The routing table maintains a list of all shards in the index. A single shard in this context has one more instances namely exactly one primary and 1 or more replicas. In other words, each instance of a shard is considered a replica while only one replica per shard is a primary replica. The primary replica can be seen as the "leader" of the shard acting as the primary entry point for operations on a specific shard.

Note: The term replica is not directly reflected in the routing table or in related classes, replicas are represented as ShardRouting.

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
static class	IndexRoutingTable.Builder

Nested classes/interfaces inherited from interface org.elasticsearch.common.io.stream.Writeable

Writeable.Reader<V>, Writeable.Writer<V>

Method Summary

Modifier and Type	Method	Description
boolean	allPrimaryShardsActive()	Returns true if all shards are primary and active.
boolean	allPrimaryShardsUnassigned()	Returns true if all primary shards are in ShardRoutingState.UNASSIGNED state.
static IndexRoutingTable.Builder	builder(Index index)
boolean	equals(Object o)
Index	getIndex()	Return the index id
ImmutableOpenIntMap<IndexShardRoutingTable>	getShards()
int	hashCode()
Iterator<IndexShardRoutingTable>	iterator()
int	numberOfNodesShardsAreAllocatedOn(String... excludedNodes)	Calculates the number of nodes that hold one or more shards of this index IndexRoutingTable excluding the nodes with the node ids give as the excludedNodes parameter.
String	prettyPrint()
int	primaryShardsActive()	Calculates the number of primary shards in active state in routing table
int	primaryShardsUnassigned()	Calculates the number of primary shards in the routing tables that are in ShardRoutingState.UNASSIGNED state.
ShardsIterator	randomAllActiveShardsIt()	Returns an unordered iterator over all active shards (including replicas).
static Diff<IndexRoutingTable>	readDiffFrom(StreamInput in)
static IndexRoutingTable	readFrom(StreamInput in)
IndexShardRoutingTable	shard(int shardId)
ImmutableOpenIntMap<IndexShardRoutingTable>	shards()
List<ShardRouting>	shardsWithState(ShardRoutingState state)	Returns a List of shards that match one of the states listed in states
void	writeTo(StreamOutput out)	Write this into the StreamOutput.

Methods inherited from class org.elasticsearch.cluster.AbstractDiffable

diff, readDiffFrom

Methods inherited from class java.lang.Object

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

Methods inherited from interface java.lang.Iterable

forEach, spliterator

Method Details

getIndex

public Index getIndex()

Return the index id

Returns:

id of the index

iterator

public Iterator<IndexShardRoutingTable> iterator()

Specified by:

iterator in interface Iterable<IndexShardRoutingTable>

numberOfNodesShardsAreAllocatedOn

public int numberOfNodesShardsAreAllocatedOn(String... excludedNodes)

Calculates the number of nodes that hold one or more shards of this index IndexRoutingTable excluding the nodes with the node ids give as the excludedNodes parameter.

Parameters:

excludedNodes - id of nodes that will be excluded

Returns:

number of distinct nodes this index has at least one shard allocated on

shards

public ImmutableOpenIntMap<IndexShardRoutingTable> shards()

getShards

public ImmutableOpenIntMap<IndexShardRoutingTable> getShards()

shard

public IndexShardRoutingTable shard(int shardId)

allPrimaryShardsActive

public boolean allPrimaryShardsActive()

Returns true if all shards are primary and active. Otherwise false.

primaryShardsActive

public int primaryShardsActive()

Calculates the number of primary shards in active state in routing table

Returns:

number of active primary shards

allPrimaryShardsUnassigned

public boolean allPrimaryShardsUnassigned()

Returns true if all primary shards are in ShardRoutingState.UNASSIGNED state. Otherwise false.

primaryShardsUnassigned

public int primaryShardsUnassigned()

Calculates the number of primary shards in the routing tables that are in ShardRoutingState.UNASSIGNED state.

shardsWithState

public List<ShardRouting> shardsWithState(ShardRoutingState state)

Returns a List of shards that match one of the states listed in states

Parameters:

state - ShardRoutingState to retrieve

Returns:

a List of shards that match one of the given states

randomAllActiveShardsIt

public ShardsIterator randomAllActiveShardsIt()

Returns an unordered iterator over all active shards (including replicas).

equals

public boolean equals(Object o)

Overrides:

equals in class Object

hashCode

public int hashCode()

Overrides:

hashCode in class Object

readFrom

public static IndexRoutingTable readFrom(StreamInput in)
                                  throws IOException

Throws:

IOException

readDiffFrom

public static Diff<IndexRoutingTable> readDiffFrom(StreamInput in)
                                            throws IOException

Throws:

IOException

writeTo

public void writeTo(StreamOutput out)
             throws IOException

Description copied from interface: Writeable

Write this into the StreamOutput.

Specified by:

writeTo in interface Writeable

Throws:

IOException

builder

public static IndexRoutingTable.Builder builder(Index index)

prettyPrint

public String prettyPrint()