org.apache.solr.cloud.api.collections

Class CreateCollectionCmd

java.lang.Object

org.apache.solr.cloud.api.collections.CreateCollectionCmd

All Implemented Interfaces:

OverseerCollectionMessageHandler.Cmd

public class CreateCollectionCmd
extends Object
implements OverseerCollectionMessageHandler.Cmd

Constructor Summary

Constructors

Constructor and Description
CreateCollectionCmd(OverseerCollectionMessageHandler ocmh)

Method Summary

Modifier and Type	Method and Description
static List<ReplicaPosition>	buildReplicaPositions(SolrCloudManager cloudManager, ClusterState clusterState, DocCollection docCollection, ZkNodeProps message, List<String> shardNames, AtomicReference<PolicyHelper.SessionWrapper> sessionWrapper)
void	call(ClusterState clusterState, ZkNodeProps message, NamedList results)
static void	checkReplicaTypes(ZkNodeProps message)
static void	createCollectionZkNode(DistribStateManager stateManager, String collection, Map<String,String> params)
static List<String>	populateShardNames(ZkNodeProps message, String router)

Methods inherited from class java.lang.Object

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

Constructor Detail

CreateCollectionCmd

public CreateCollectionCmd(OverseerCollectionMessageHandler ocmh)

Method Detail

call

public void call(ClusterState clusterState,
                 ZkNodeProps message,
                 NamedList results)
          throws Exception

Specified by:

call in interface OverseerCollectionMessageHandler.Cmd

Throws:

Exception

buildReplicaPositions

public static List<ReplicaPosition> buildReplicaPositions(SolrCloudManager cloudManager,
                                                          ClusterState clusterState,
                                                          DocCollection docCollection,
                                                          ZkNodeProps message,
                                                          List<String> shardNames,
                                                          AtomicReference<PolicyHelper.SessionWrapper> sessionWrapper)
                                                   throws IOException,
                                                          InterruptedException,
                                                          Assign.AssignmentException

Throws:

IOException

InterruptedException

Assign.AssignmentException

checkReplicaTypes

public static void checkReplicaTypes(ZkNodeProps message)

populateShardNames

public static List<String> populateShardNames(ZkNodeProps message,
                                              String router)

createCollectionZkNode

public static void createCollectionZkNode(DistribStateManager stateManager,
                                          String collection,
                                          Map<String,String> params)