org.elasticsearch.cluster.routing

Class IndexShardRoutingTable

java.lang.Object

org.elasticsearch.cluster.routing.IndexShardRoutingTable

All Implemented Interfaces:

java.lang.Iterable<ShardRouting>

public class IndexShardRoutingTable
extends java.lang.Object
implements java.lang.Iterable<ShardRouting>

IndexShardRoutingTable encapsulates all instances of a single shard. Each Elasticsearch index consists of multiple shards, each shard encapsulates a disjoint set of the index data and each shard has one or more instances referred to as replicas of a shard. Given that, this class encapsulates all replicas (instances) for a single index shard.

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static class	IndexShardRoutingTable.Builder

Method Summary

Modifier and Type	Method and Description
ShardIterator	activeInitializingShardsIt(int seed) Returns an iterator over active and initializing shards.
ShardIterator	activeInitializingShardsRandomIt() Returns an iterator over active and initializing shards.
java.util.List<ShardRouting>	activeShards() Returns a List of active shards
boolean	allShardsStarted() Returns true iff all shards in the routing table are started otherwise false
java.util.List<ShardRouting>	assignedShards() Returns a List of assigned shards
boolean	equals(java.lang.Object o)
java.util.List<ShardRouting>	getActiveShards() Returns a List of active shards
java.util.List<ShardRouting>	getAllInitializingShards() Returns a List of all initializing shards, including target shards of relocations
java.util.List<ShardRouting>	getAssignedShards() Returns a List of assigned shards
ShardId	getShardId() Returns the shards id
java.util.List<ShardRouting>	getShards() Returns a List of shards
int	getSize() Returns the number of this shards instances.
int	hashCode()
java.util.Iterator<ShardRouting>	iterator()
ShardIterator	onlyNodeActiveInitializingShardsIt(java.lang.String nodeId)
ShardIterator	onlyNodeSelectorActiveInitializingShardsIt(java.lang.String[] nodeAttributes, DiscoveryNodes discoveryNodes) Returns shards based on nodeAttributes given such as node name , node attribute, node IP Supports node specifications in cluster API
ShardIterator	onlyNodeSelectorActiveInitializingShardsIt(java.lang.String nodeAttributes, DiscoveryNodes discoveryNodes)
ShardIterator	preferAttributesActiveInitializingShardsIt(java.lang.String[] attributes, DiscoveryNodes nodes)
ShardIterator	preferAttributesActiveInitializingShardsIt(java.lang.String[] attributes, DiscoveryNodes nodes, int seed)
ShardIterator	preferNodeActiveInitializingShardsIt(java.util.Set<java.lang.String> nodeIds)
ShardIterator	primaryActiveInitializingShardIt()
ShardIterator	primaryFirstActiveInitializingShardsIt()
ShardRouting	primaryShard()
ShardIterator	primaryShardIt() Returns an iterator only on the primary shard.
ShardIterator	replicaActiveInitializingShardIt()
ShardIterator	replicaFirstActiveInitializingShardsIt()
java.util.List<ShardRouting>	replicaShards()
java.util.List<ShardRouting>	replicaShardsWithState(ShardRoutingState... states)
ShardId	shardId() Returns the shards id
java.util.List<ShardRouting>	shards() Returns a List of shards
ShardIterator	shardsIt()
ShardIterator	shardsIt(int seed)
ShardIterator	shardsRandomIt()
java.util.List<ShardRouting>	shardsWithState(ShardRoutingState state)
int	size() Returns the number of this shards instances.

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 Detail

shardId

public ShardId shardId()

Returns the shards id

Returns:

id of the shard

getShardId

public ShardId getShardId()

Returns the shards id

Returns:

id of the shard

iterator

public java.util.Iterator<ShardRouting> iterator()

Specified by:

iterator in interface java.lang.Iterable<ShardRouting>

size

public int size()

Returns the number of this shards instances.

getSize

public int getSize()

Returns the number of this shards instances.

shards

public java.util.List<ShardRouting> shards()

Returns a List of shards

Returns:

a List of shards

getShards

public java.util.List<ShardRouting> getShards()

Returns a List of shards

Returns:

a List of shards

activeShards

public java.util.List<ShardRouting> activeShards()

Returns a List of active shards

Returns:

a List of shards

getAllInitializingShards

public java.util.List<ShardRouting> getAllInitializingShards()

Returns a List of all initializing shards, including target shards of relocations

Returns:

a List of shards

getActiveShards

public java.util.List<ShardRouting> getActiveShards()

Returns a List of active shards

Returns:

a List of shards

assignedShards

public java.util.List<ShardRouting> assignedShards()

Returns a List of assigned shards

Returns:

a List of shards

getAssignedShards

public java.util.List<ShardRouting> getAssignedShards()

Returns a List of assigned shards

Returns:

a List of shards

shardsRandomIt

public ShardIterator shardsRandomIt()

shardsIt

public ShardIterator shardsIt()

shardsIt

public ShardIterator shardsIt(int seed)

activeInitializingShardsRandomIt

public ShardIterator activeInitializingShardsRandomIt()

Returns an iterator over active and initializing shards. Making sure though that its random within the active shards, and initializing shards are the last to iterate through.

activeInitializingShardsIt

public ShardIterator activeInitializingShardsIt(int seed)

Returns an iterator over active and initializing shards. Making sure though that its random within the active shards, and initializing shards are the last to iterate through.

primaryShardIt

public ShardIterator primaryShardIt()

Returns an iterator only on the primary shard.

primaryActiveInitializingShardIt

public ShardIterator primaryActiveInitializingShardIt()

primaryFirstActiveInitializingShardsIt

public ShardIterator primaryFirstActiveInitializingShardsIt()

replicaActiveInitializingShardIt

public ShardIterator replicaActiveInitializingShardIt()

replicaFirstActiveInitializingShardsIt

public ShardIterator replicaFirstActiveInitializingShardsIt()

onlyNodeActiveInitializingShardsIt

public ShardIterator onlyNodeActiveInitializingShardsIt(java.lang.String nodeId)

onlyNodeSelectorActiveInitializingShardsIt

public ShardIterator onlyNodeSelectorActiveInitializingShardsIt(java.lang.String nodeAttributes,
                                                                DiscoveryNodes discoveryNodes)

onlyNodeSelectorActiveInitializingShardsIt

public ShardIterator onlyNodeSelectorActiveInitializingShardsIt(java.lang.String[] nodeAttributes,
                                                                DiscoveryNodes discoveryNodes)

Returns shards based on nodeAttributes given such as node name , node attribute, node IP Supports node specifications in cluster API

preferNodeActiveInitializingShardsIt

public ShardIterator preferNodeActiveInitializingShardsIt(java.util.Set<java.lang.String> nodeIds)

equals

public boolean equals(java.lang.Object o)

Overrides:

equals in class java.lang.Object

hashCode

public int hashCode()

Overrides:

hashCode in class java.lang.Object

allShardsStarted

public boolean allShardsStarted()

Returns true iff all shards in the routing table are started otherwise false

preferAttributesActiveInitializingShardsIt

public ShardIterator preferAttributesActiveInitializingShardsIt(java.lang.String[] attributes,
                                                                DiscoveryNodes nodes)

preferAttributesActiveInitializingShardsIt

public ShardIterator preferAttributesActiveInitializingShardsIt(java.lang.String[] attributes,
                                                                DiscoveryNodes nodes,
                                                                int seed)

primaryShard

public ShardRouting primaryShard()

replicaShards

public java.util.List<ShardRouting> replicaShards()

replicaShardsWithState

public java.util.List<ShardRouting> replicaShardsWithState(ShardRoutingState... states)

shardsWithState

public java.util.List<ShardRouting> shardsWithState(ShardRoutingState state)