Package org.apache.solr.cloud.api.collections

Class Assign

java.lang.Object

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

public class Assign
extends Object

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
static class	Assign.AssignmentException	Thrown if there is an exception while assigning nodes for replicas
static class	Assign.AssignRequest
static class	Assign.AssignRequestBuilder
static interface	Assign.AssignStrategy	Strategy for assigning replicas to nodes.

Constructor Summary

Constructors

Constructor	Description
Assign()

Method Summary

Modifier and Type	Method	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(String collectionName, String shard, Replica.Type type, int replicaNum)
static String	buildSolrCoreName(DistribStateManager stateManager, String collectionName, DocCollection collection, String shard, Replica.Type type, boolean newCollection)
static String	buildSolrCoreName(DistribStateManager stateManager, DocCollection collection, String shard, Replica.Type type)
static Assign.AssignStrategy	createAssignStrategy(CoreContainer coreContainer)	Creates the appropriate instance of Assign.AssignStrategy based on how the cluster and/or individual collections are configured.
static Collection<String>	filterNonDataNodes(DistribStateManager zk, Collection<String> liveNodes)
static String	getCounterNodePath(String collection)
static List<String>	getLiveOrLiveAndCreateNodeSetList(Set<String> liveNodes, ZkNodeProps message, Random random, DistribStateManager zk)
static List<ReplicaPosition>	getNodesForNewReplicas(ClusterState clusterState, String collectionName, String shard, int nrtReplicas, int tlogReplicas, int pullReplicas, Object createNodeSet, SolrCloudManager cloudManager, CoreContainer coreContainer)
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(String collectionName,
                                       String shard,
                                       Replica.Type type,
                                       int replicaNum)

buildSolrCoreName

public static String buildSolrCoreName(DistribStateManager stateManager,
                                       String collectionName,
                                       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,
                                                             DistribStateManager zk)

filterNonDataNodes

public static Collection<String> filterNonDataNodes(DistribStateManager zk,
                                                    Collection<String> liveNodes)

getNodesForNewReplicas

public static List<ReplicaPosition> getNodesForNewReplicas(ClusterState clusterState,
                                                           String collectionName,
                                                           String shard,
                                                           int nrtReplicas,
                                                           int tlogReplicas,
                                                           int pullReplicas,
                                                           Object createNodeSet,
                                                           SolrCloudManager cloudManager,
                                                           CoreContainer coreContainer)
                                                    throws IOException,
                                                           InterruptedException,
                                                           Assign.AssignmentException

Throws:

IOException

InterruptedException

Assign.AssignmentException

createAssignStrategy

public static Assign.AssignStrategy createAssignStrategy(CoreContainer coreContainer)

Creates the appropriate instance of Assign.AssignStrategy based on how the cluster and/or individual collections are configured.

If PlacementPlugin instance is null this call will return a strategy from SimplePlacementFactory, otherwise PlacementPluginAssignStrategy will be used.