Package org.elasticsearch.index.shard

Class ReplicationGroup

java.lang.Object
org.elasticsearch.index.shard.ReplicationGroup
public class ReplicationGroup
extends java.lang.Object
Replication group for a shard. Used by a primary shard to coordinate replication and recoveries.

  • Constructor Summary

    Constructors 
    Constructor Description
    ReplicationGroup​(IndexShardRoutingTable routingTable, java.util.Set<java.lang.String> inSyncAllocationIds, java.util.Set<java.lang.String> trackedAllocationIds)  

  • Method Summary

    Modifier and Type Method Description
    boolean equals​(java.lang.Object o)  
    java.util.Set<java.lang.String> getInSyncAllocationIds()  
    java.util.List<ShardRouting> getReplicationTargets()
    Returns the subset of shards in the routing table that should be replicated to.
    IndexShardRoutingTable getRoutingTable()  
    java.util.List<ShardRouting> getSkippedShards()
    Returns the subset of shards in the routing table that are unassigned or initializing and not ready yet to receive operations (i.e.
    java.util.Set<java.lang.String> getUnavailableInSyncShards()
    Returns the set of shard allocation ids that are in the in-sync set but have no assigned routing entry
    int hashCode()  
    java.lang.String toString()  

    Methods inherited from class java.lang.Object

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

  • Constructor Details

    • ReplicationGroup

      public ReplicationGroup​(IndexShardRoutingTable routingTable, java.util.Set<java.lang.String> inSyncAllocationIds, java.util.Set<java.lang.String> trackedAllocationIds)

  • Method Details

    • getRoutingTable

      public IndexShardRoutingTable getRoutingTable()

    • getInSyncAllocationIds

      public java.util.Set<java.lang.String> getInSyncAllocationIds()

    • getUnavailableInSyncShards

      public java.util.Set<java.lang.String> getUnavailableInSyncShards()
      Returns the set of shard allocation ids that are in the in-sync set but have no assigned routing entry

    • getReplicationTargets

      public java.util.List<ShardRouting> getReplicationTargets()
      Returns the subset of shards in the routing table that should be replicated to. Includes relocation targets.

    • getSkippedShards

      public java.util.List<ShardRouting> getSkippedShards()
      Returns the subset of shards in the routing table that are unassigned or initializing and not ready yet to receive operations (i.e. engine not opened yet). Includes relocation targets.

    • 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

    • toString

      public java.lang.String toString()
      Overrides:
      toString in class java.lang.Object