org.apache.solr.cloud

Class Assign

java.lang.Object

org.apache.solr.cloud.Assign

public class Assign
extends Object

Constructor Summary

Constructors

Constructor and Description
Assign()

Method Summary

Modifier and Type	Method and Description
static String	assignNode(SolrZkClient client, DocCollection collection)
static String	assignShard(DocCollection collection, Integer numShards) Assign a new unique id up to slices count - then add replicas evenly.
static String	buildCoreName(SolrZkClient zkClient, DocCollection collection, String shard, Replica.Type type)
static String	buildCoreName(SolrZkClient zkClient, DocCollection collection, String shard, Replica.Type type, boolean newCollection)
static List<String>	getLiveOrLiveAndCreateNodeSetList(Set<String> liveNodes, ZkNodeProps message, Random random)
static List<org.apache.solr.cloud.Assign.ReplicaCount>	getNodesForNewReplicas(ClusterState clusterState, String collectionName, String shard, int nrtReplicas, Object createNodeSet, CoreContainer cc)
static List<ReplicaPosition>	getPositionsUsingPolicy(String collName, List<String> shardNames, int nrtReplicas, int tlogReplicas, int pullReplicas, String policyName, ZkStateReader zkStateReader, List<String> nodesList)
static List<ReplicaPosition>	identifyNodes(OverseerCollectionMessageHandler ocmh, ClusterState clusterState, List<String> nodeList, String collectionName, ZkNodeProps message, List<String> shardNames, int numNrtReplicas, int numTlogReplicas, int numPullReplicas)
static int	incAndGetId(SolrZkClient zkClient, 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

incAndGetId

public static int incAndGetId(SolrZkClient zkClient,
                              String collection,
                              int defaultValue)

assignNode

public static String assignNode(SolrZkClient client,
                                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

buildCoreName

public static String buildCoreName(SolrZkClient zkClient,
                                   DocCollection collection,
                                   String shard,
                                   Replica.Type type,
                                   boolean newCollection)

buildCoreName

public static String buildCoreName(SolrZkClient zkClient,
                                   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(OverseerCollectionMessageHandler ocmh,
                                                  ClusterState clusterState,
                                                  List<String> nodeList,
                                                  String collectionName,
                                                  ZkNodeProps message,
                                                  List<String> shardNames,
                                                  int numNrtReplicas,
                                                  int numTlogReplicas,
                                                  int numPullReplicas)
                                           throws org.apache.zookeeper.KeeperException,
                                                  InterruptedException

Throws:

org.apache.zookeeper.KeeperException

InterruptedException

getNodesForNewReplicas

public static List<org.apache.solr.cloud.Assign.ReplicaCount> getNodesForNewReplicas(ClusterState clusterState,
                                                                                     String collectionName,
                                                                                     String shard,
                                                                                     int nrtReplicas,
                                                                                     Object createNodeSet,
                                                                                     CoreContainer cc)
                                                                              throws org.apache.zookeeper.KeeperException,
                                                                                     InterruptedException

Throws:

org.apache.zookeeper.KeeperException

InterruptedException

getPositionsUsingPolicy

public static List<ReplicaPosition> getPositionsUsingPolicy(String collName,
                                                            List<String> shardNames,
                                                            int nrtReplicas,
                                                            int tlogReplicas,
                                                            int pullReplicas,
                                                            String policyName,
                                                            ZkStateReader zkStateReader,
                                                            List<String> nodesList)
                                                     throws org.apache.zookeeper.KeeperException,
                                                            InterruptedException

Throws:

org.apache.zookeeper.KeeperException

InterruptedException