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

  • Method Details

    • 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