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 Description CreateCollectionCmd(OverseerCollectionMessageHandler ocmh)
-
Method Summary
All Methods Static Methods Instance Methods Concrete Methods Modifier and Type Method 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)
-
-
-
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 interfaceOverseerCollectionMessageHandler.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
-
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)
-
-