Package org.elasticsearch.index.shard

Class 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 Detail

      • ReplicationGroup

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

    • Method Detail

      • 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