Package org.apache.solr.common.cloud

Class PerReplicaStatesOps

java.lang.Object

org.apache.solr.common.cloud.PerReplicaStatesOps

public class PerReplicaStatesOps
extends Object

This is a helper class that encapsulates various operations performed on the per-replica states Do not directly manipulate the per replica states as it can become difficult to debug them

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
static class	PerReplicaStatesOps.PrsZkNodeNotFoundException

Method Summary

Modifier and Type	Method	Description
static PerReplicaStatesOps	addReplica(String replica, org.apache.solr.common.cloud.Replica.State state, boolean isLeader, org.apache.solr.common.cloud.PerReplicaStates rs)
static PerReplicaStatesOps	deleteReplica(String replica, org.apache.solr.common.cloud.PerReplicaStates rs)	Delete a replica entry from per-replica states
static PerReplicaStatesOps	disable(org.apache.solr.common.cloud.PerReplicaStates rs)	Switch a collection /to perReplicaState=false
static PerReplicaStatesOps	downReplicas(List<String> replicas, org.apache.solr.common.cloud.PerReplicaStates rs)	Mark the given replicas as DOWN
static PerReplicaStatesOps	enable(org.apache.solr.common.cloud.DocCollection coll, org.apache.solr.common.cloud.PerReplicaStates rs)	Switch a collection /to perReplicaState=true
static org.apache.solr.common.cloud.PerReplicaStates	fetch(String path, SolrZkClient zkClient, org.apache.solr.common.cloud.PerReplicaStates current)	Fetch the latest PerReplicaStates .
static PerReplicaStatesOps	flipLeader(Set<String> allReplicas, String next, org.apache.solr.common.cloud.PerReplicaStates rs)	Flip the leader replica to a new one
static PerReplicaStatesOps	flipState(String replica, org.apache.solr.common.cloud.Replica.State newState, org.apache.solr.common.cloud.PerReplicaStates rs)	Change the state of a replica
List<org.apache.solr.common.cloud.PerReplicaStates.Operation>	get()
List<org.apache.solr.common.cloud.PerReplicaStates.Operation>	get(org.apache.solr.common.cloud.PerReplicaStates rs)
org.apache.solr.common.cloud.PerReplicaStates	getPerReplicaStates()
static org.apache.solr.common.cloud.DocCollection.PrsSupplier	getZkClientPrsSupplier(SolrZkClient zkClient, String collectionPath)
void	persist(String znode, SolrZkClient zkClient)	This is a persist operation with retry if a write fails due to stale state
String	toString()

Methods inherited from class java.lang.Object

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

Method Detail

fetch

public static org.apache.solr.common.cloud.PerReplicaStates fetch(String path,
                                                                  SolrZkClient zkClient,
                                                                  org.apache.solr.common.cloud.PerReplicaStates current)

Fetch the latest PerReplicaStates . It fetches data after checking the Stat.getCversion() of state.json. If this is not modified, the same object is returned

getZkClientPrsSupplier

public static org.apache.solr.common.cloud.DocCollection.PrsSupplier getZkClientPrsSupplier(SolrZkClient zkClient,
                                                                                            String collectionPath)

persist

public void persist(String znode,
                    SolrZkClient zkClient)
             throws org.apache.zookeeper.KeeperException,
                    InterruptedException

This is a persist operation with retry if a write fails due to stale state

Throws:

org.apache.zookeeper.KeeperException

InterruptedException

getPerReplicaStates

public org.apache.solr.common.cloud.PerReplicaStates getPerReplicaStates()

flipState

public static PerReplicaStatesOps flipState(String replica,
                                            org.apache.solr.common.cloud.Replica.State newState,
                                            org.apache.solr.common.cloud.PerReplicaStates rs)

Change the state of a replica

Parameters:

newState - the new state

enable

public static PerReplicaStatesOps enable(org.apache.solr.common.cloud.DocCollection coll,
                                         org.apache.solr.common.cloud.PerReplicaStates rs)

Switch a collection /to perReplicaState=true

disable

public static PerReplicaStatesOps disable(org.apache.solr.common.cloud.PerReplicaStates rs)

Switch a collection /to perReplicaState=false

flipLeader

public static PerReplicaStatesOps flipLeader(Set<String> allReplicas,
                                             String next,
                                             org.apache.solr.common.cloud.PerReplicaStates rs)

Flip the leader replica to a new one

Parameters:

allReplicas - allReplicas of the shard

next - next leader

deleteReplica

public static PerReplicaStatesOps deleteReplica(String replica,
                                                org.apache.solr.common.cloud.PerReplicaStates rs)

Delete a replica entry from per-replica states

Parameters:

replica - name of the replica to be deleted

addReplica

public static PerReplicaStatesOps addReplica(String replica,
                                             org.apache.solr.common.cloud.Replica.State state,
                                             boolean isLeader,
                                             org.apache.solr.common.cloud.PerReplicaStates rs)

downReplicas

public static PerReplicaStatesOps downReplicas(List<String> replicas,
                                               org.apache.solr.common.cloud.PerReplicaStates rs)

Mark the given replicas as DOWN

get

public List<org.apache.solr.common.cloud.PerReplicaStates.Operation> get()

get

public List<org.apache.solr.common.cloud.PerReplicaStates.Operation> get(org.apache.solr.common.cloud.PerReplicaStates rs)

toString

public String toString()

Overrides:

toString in class Object