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