org.apache.solr.cloud

Class ActiveReplicaWatcher

java.lang.Object

org.apache.solr.cloud.ActiveReplicaWatcher

All Implemented Interfaces:

CollectionStateWatcher

public class ActiveReplicaWatcher
extends Object
implements CollectionStateWatcher

Watch for replicas to become Replica.State.ACTIVE. Watcher is terminated (its onStateChanged(Set, DocCollection) method returns false) when all listed replicas become active.

Additionally, the provided SolrCloseableLatch instance can be used to await for all listed replicas to become active.

Constructor Summary

Constructors

Constructor and Description
ActiveReplicaWatcher(String collection, List<String> replicaIds, List<String> solrCoreNames, SolrCloseableLatch latch) Construct the watcher.

Method Summary

Modifier and Type	Method and Description
List<Replica>	getActiveReplicas() Return the list of active replicas found so far.
String	getCollection() Collection name.
List<String>	getReplicaIds() Return the list of replica id-s that are not active yet (or unverified).
List<String>	getSolrCoreNames() Return a list of SolrCore names that are not active yet (or unverified).
boolean	onStateChanged(Set<String> liveNodes, DocCollection collectionState)
String	toString()

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait

Constructor Detail

ActiveReplicaWatcher

public ActiveReplicaWatcher(String collection,
                            List<String> replicaIds,
                            List<String> solrCoreNames,
                            SolrCloseableLatch latch)

Construct the watcher. At least one replicaId or solrCoreName must be provided.

Parameters:

collection - collection name

replicaIds - list of replica id-s

solrCoreNames - list of SolrCore names

latch - optional latch to await for all provided replicas to become active. This latch will be counted down by at most the number of provided replica id-s / SolrCore names.

Method Detail

getCollection

public String getCollection()

Collection name.

getActiveReplicas

public List<Replica> getActiveReplicas()

Return the list of active replicas found so far.

getReplicaIds

public List<String> getReplicaIds()

Return the list of replica id-s that are not active yet (or unverified).

getSolrCoreNames

public List<String> getSolrCoreNames()

Return a list of SolrCore names that are not active yet (or unverified).

toString

public String toString()

Overrides:

toString in class Object

onStateChanged

public boolean onStateChanged(Set<String> liveNodes,
                              DocCollection collectionState)

Specified by:

onStateChanged in interface CollectionStateWatcher