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.Modifier and Type | Class | Description |
---|---|---|
static class |
IndexShardRoutingTable.Builder |
Modifier and Type | Method | Description |
---|---|---|
ShardIterator |
activeInitializingShardsIt(int seed) |
Returns an iterator over active and initializing shards.
|
ShardIterator |
activeInitializingShardsRandomIt() |
Returns an iterator over active and initializing shards.
|
ShardIterator |
activeInitializingShardsRankedIt(ResponseCollectorService collector,
java.util.Map<java.lang.String,java.lang.Long> nodeSearchCounts) |
Returns an iterator over active and initializing shards, ordered by the adaptive replica
selection forumla.
|
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.Set<java.lang.String> |
getAllAllocationIds() |
|
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 |
ShardRouting |
getByAllocationId(java.lang.String allocationId) |
|
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.util.List<java.lang.String> attributes,
DiscoveryNodes nodes) |
|
ShardIterator |
preferAttributesActiveInitializingShardsIt(java.util.List<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.
|
java.lang.String |
toString() |
public ShardId shardId()
public ShardId getShardId()
public java.util.Iterator<ShardRouting> iterator()
iterator
in interface java.lang.Iterable<ShardRouting>
public int size()
public int getSize()
public java.util.List<ShardRouting> shards()
List
of shardsList
of shardspublic java.util.List<ShardRouting> getShards()
List
of shardsList
of shardspublic java.util.List<ShardRouting> activeShards()
List
of active shardsList
of shardspublic java.util.List<ShardRouting> getAllInitializingShards()
List
of all initializing shards, including target shards of relocationsList
of shardspublic java.util.List<ShardRouting> getActiveShards()
List
of active shardsList
of shardspublic java.util.List<ShardRouting> assignedShards()
List
of assigned shardsList
of shardspublic java.util.List<ShardRouting> getAssignedShards()
List
of assigned shardsList
of shardspublic ShardIterator shardsRandomIt()
public ShardIterator shardsIt()
public ShardIterator shardsIt(int seed)
public ShardIterator activeInitializingShardsRandomIt()
public ShardIterator activeInitializingShardsIt(int seed)
public ShardIterator activeInitializingShardsRankedIt(@Nullable ResponseCollectorService collector, @Nullable java.util.Map<java.lang.String,java.lang.Long> nodeSearchCounts)
public ShardIterator primaryShardIt()
public ShardIterator primaryActiveInitializingShardIt()
public ShardIterator primaryFirstActiveInitializingShardsIt()
public ShardIterator replicaActiveInitializingShardIt()
public ShardIterator replicaFirstActiveInitializingShardsIt()
public ShardIterator onlyNodeActiveInitializingShardsIt(java.lang.String nodeId)
public ShardIterator onlyNodeSelectorActiveInitializingShardsIt(java.lang.String nodeAttributes, DiscoveryNodes discoveryNodes)
public ShardIterator onlyNodeSelectorActiveInitializingShardsIt(java.lang.String[] nodeAttributes, DiscoveryNodes discoveryNodes)
public ShardIterator preferNodeActiveInitializingShardsIt(java.util.Set<java.lang.String> nodeIds)
public boolean equals(java.lang.Object o)
equals
in class java.lang.Object
public int hashCode()
hashCode
in class java.lang.Object
public boolean allShardsStarted()
true
iff all shards in the routing table are started otherwise false
@Nullable public ShardRouting getByAllocationId(java.lang.String allocationId)
public java.util.Set<java.lang.String> getAllAllocationIds()
public ShardIterator preferAttributesActiveInitializingShardsIt(java.util.List<java.lang.String> attributes, DiscoveryNodes nodes)
public ShardIterator preferAttributesActiveInitializingShardsIt(java.util.List<java.lang.String> attributes, DiscoveryNodes nodes, int seed)
public ShardRouting primaryShard()
public java.util.List<ShardRouting> replicaShards()
public java.util.List<ShardRouting> replicaShardsWithState(ShardRoutingState... states)
public java.util.List<ShardRouting> shardsWithState(ShardRoutingState state)
public java.lang.String toString()
toString
in class java.lang.Object