Package org.elasticsearch.index.shard

Class ReplicationGroup

java.lang.Object

org.elasticsearch.index.shard.ReplicationGroup

public class ReplicationGroup
extends Object

Replication group for a shard. Used by a primary shard to coordinate replication and recoveries.

Constructor Summary

Constructors

Constructor	Description
ReplicationGroup(IndexShardRoutingTable routingTable, Set<String> inSyncAllocationIds, Set<String> trackedAllocationIds, long version)

Method Summary

Modifier and Type	Method	Description
boolean	equals(Object o)
Set<String>	getInSyncAllocationIds()
List<ShardRouting>	getReplicationTargets()	Returns the subset of shards in the routing table that should be replicated to.
IndexShardRoutingTable	getRoutingTable()
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.
Set<String>	getTrackedAllocationIds()
Set<String>	getUnavailableInSyncShards()	Returns the set of shard allocation ids that are in the in-sync set but have no assigned routing entry
long	getVersion()
int	hashCode()
String	toString()

Methods inherited from class java.lang.Object

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

Constructor Details

ReplicationGroup

public ReplicationGroup(IndexShardRoutingTable routingTable,
 Set<String> inSyncAllocationIds,
 Set<String> trackedAllocationIds,
 long version)

Method Details

getVersion

public long getVersion()

getRoutingTable

public IndexShardRoutingTable getRoutingTable()

getInSyncAllocationIds

public Set<String> getInSyncAllocationIds()

getTrackedAllocationIds

public Set<String> getTrackedAllocationIds()

getUnavailableInSyncShards

public Set<String> getUnavailableInSyncShards()

Returns the set of shard allocation ids that are in the in-sync set but have no assigned routing entry

getReplicationTargets

public List<ShardRouting> getReplicationTargets()

Returns the subset of shards in the routing table that should be replicated to. Includes relocation targets.

getSkippedShards

public 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(Object o)

Overrides:

equals in class Object

hashCode

public int hashCode()

Overrides:

hashCode in class Object

toString

public String toString()

Overrides:

toString in class Object