org.apache.solr.cloud.api.collections

Class Assign

java.lang.Object

org.apache.solr.cloud.api.collections.Assign

public class Assign
extends Object

Constructor Summary

Constructors

Constructor and Description
Assign()

Method Summary

Modifier and Type	Method and Description
static String	assignCoreNodeName(DistribStateManager stateManager, DocCollection collection)
static String	assignShard(DocCollection collection, Integer numShards) Assign a new unique id up to slices count - then add replicas evenly.
static String	buildSolrCoreName(DistribStateManager stateManager, DocCollection collection, String shard, Replica.Type type)
static String	buildSolrCoreName(DistribStateManager stateManager, DocCollection collection, String shard, Replica.Type type, boolean newCollection)
static String	getCounterNodePath(String collection)
static List<String>	getLiveOrLiveAndCreateNodeSetList(Set<String> liveNodes, ZkNodeProps message, Random random)
static List<org.apache.solr.cloud.api.collections.Assign.ReplicaCount>	getNodesForNewReplicas(ClusterState clusterState, String collectionName, String shard, int nrtReplicas, Object createNodeSet, SolrCloudManager cloudManager)
static List<ReplicaPosition>	getPositionsUsingPolicy(String collName, List<String> shardNames, int nrtReplicas, int tlogReplicas, int pullReplicas, String policyName, SolrCloudManager cloudManager, List<String> nodesList)
static List<ReplicaPosition>	identifyNodes(SolrCloudManager cloudManager, ClusterState clusterState, List<String> nodeList, String collectionName, ZkNodeProps message, List<String> shardNames, int numNrtReplicas, int numTlogReplicas, int numPullReplicas)
static int	incAndGetId(DistribStateManager stateManager, String collection, int defaultValue)

Methods inherited from class java.lang.Object

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

Constructor Detail

Assign

public Assign()

Method Detail

getCounterNodePath

public static String getCounterNodePath(String collection)

incAndGetId

public static int incAndGetId(DistribStateManager stateManager,
                              String collection,
                              int defaultValue)

assignCoreNodeName

public static String assignCoreNodeName(DistribStateManager stateManager,
                                        DocCollection collection)

assignShard

public static String assignShard(DocCollection collection,
                                 Integer numShards)

Assign a new unique id up to slices count - then add replicas evenly.

Returns:

the assigned shard id

buildSolrCoreName

public static String buildSolrCoreName(DistribStateManager stateManager,
                                       DocCollection collection,
                                       String shard,
                                       Replica.Type type,
                                       boolean newCollection)

buildSolrCoreName

public static String buildSolrCoreName(DistribStateManager stateManager,
                                       DocCollection collection,
                                       String shard,
                                       Replica.Type type)

getLiveOrLiveAndCreateNodeSetList

public static List<String> getLiveOrLiveAndCreateNodeSetList(Set<String> liveNodes,
                                                             ZkNodeProps message,
                                                             Random random)

identifyNodes

public static List<ReplicaPosition> identifyNodes(SolrCloudManager cloudManager,
                                                  ClusterState clusterState,
                                                  List<String> nodeList,
                                                  String collectionName,
                                                  ZkNodeProps message,
                                                  List<String> shardNames,
                                                  int numNrtReplicas,
                                                  int numTlogReplicas,
                                                  int numPullReplicas)
                                           throws IOException,
                                                  InterruptedException

Throws:

IOException

InterruptedException

getNodesForNewReplicas

public static List<org.apache.solr.cloud.api.collections.Assign.ReplicaCount> getNodesForNewReplicas(ClusterState clusterState,
                                                                                                     String collectionName,
                                                                                                     String shard,
                                                                                                     int nrtReplicas,
                                                                                                     Object createNodeSet,
                                                                                                     SolrCloudManager cloudManager)
                                                                                              throws IOException,
                                                                                                     InterruptedException

Throws:

IOException

InterruptedException

getPositionsUsingPolicy

public static List<ReplicaPosition> getPositionsUsingPolicy(String collName,
                                                            List<String> shardNames,
                                                            int nrtReplicas,
                                                            int tlogReplicas,
                                                            int pullReplicas,
                                                            String policyName,
                                                            SolrCloudManager cloudManager,
                                                            List<String> nodesList)
                                                     throws IOException,
                                                            InterruptedException

Throws:

IOException

InterruptedException