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

Class SplitShardCmd

java.lang.Object

org.apache.solr.cloud.api.collections.SplitShardCmd

All Implemented Interfaces:

CollApiCmds.CollectionApiCommand

public class SplitShardCmd
extends Object
implements CollApiCmds.CollectionApiCommand

Field Summary

Fields

Modifier and Type	Field	Description
static String	SHARDSPLIT_CHECKDISKSPACE_ENABLED

Constructor Summary

Constructors

Constructor	Description
SplitShardCmd(CollectionCommandContext ccc)

Method Summary

Modifier and Type	Method	Description
void	call(org.apache.solr.common.cloud.ClusterState state, org.apache.solr.common.cloud.ZkNodeProps message, org.apache.solr.common.util.NamedList<Object> results)
static void	checkDiskSpace(String collection, String shard, org.apache.solr.common.cloud.Replica parentShardLeader, SolrIndexSplitter.SplitMethod method, org.apache.solr.client.solrj.cloud.SolrCloudManager cloudManager)
static String	fillRanges(org.apache.solr.client.solrj.cloud.SolrCloudManager cloudManager, org.apache.solr.common.cloud.ZkNodeProps message, org.apache.solr.common.cloud.DocCollection collection, org.apache.solr.common.cloud.Slice parentSlice, List<org.apache.solr.common.cloud.DocRouter.Range> subRanges, List<String> subSlices, List<String> subShardNames, boolean firstReplicaNrt)
static org.apache.solr.common.cloud.Slice	getParentSlice(org.apache.solr.common.cloud.ClusterState clusterState, String collectionName, AtomicReference<String> slice, String splitKey)
static boolean	lockForSplit(org.apache.solr.client.solrj.cloud.SolrCloudManager cloudManager, String collection, String shard)
boolean	split(org.apache.solr.common.cloud.ClusterState clusterState, org.apache.solr.common.cloud.ZkNodeProps message, org.apache.solr.common.util.NamedList<Object> results)
static void	unlockForSplit(org.apache.solr.client.solrj.cloud.SolrCloudManager cloudManager, String collection, String shard)

Methods inherited from class java.lang.Object

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

Field Detail

SHARDSPLIT_CHECKDISKSPACE_ENABLED

public static final String SHARDSPLIT_CHECKDISKSPACE_ENABLED

See Also:

Constant Field Values

Constructor Detail

SplitShardCmd

public SplitShardCmd(CollectionCommandContext ccc)

Method Detail

call

public void call(org.apache.solr.common.cloud.ClusterState state,
                 org.apache.solr.common.cloud.ZkNodeProps message,
                 org.apache.solr.common.util.NamedList<Object> results)
          throws Exception

Specified by:

call in interface CollApiCmds.CollectionApiCommand

Throws:

Exception

split

public boolean split(org.apache.solr.common.cloud.ClusterState clusterState,
                     org.apache.solr.common.cloud.ZkNodeProps message,
                     org.apache.solr.common.util.NamedList<Object> results)
              throws Exception

Throws:

Exception

checkDiskSpace

public static void checkDiskSpace(String collection,
                                  String shard,
                                  org.apache.solr.common.cloud.Replica parentShardLeader,
                                  SolrIndexSplitter.SplitMethod method,
                                  org.apache.solr.client.solrj.cloud.SolrCloudManager cloudManager)
                           throws org.apache.solr.common.SolrException

Throws:

org.apache.solr.common.SolrException

getParentSlice

public static org.apache.solr.common.cloud.Slice getParentSlice(org.apache.solr.common.cloud.ClusterState clusterState,
                                                                String collectionName,
                                                                AtomicReference<String> slice,
                                                                String splitKey)

fillRanges

public static String fillRanges(org.apache.solr.client.solrj.cloud.SolrCloudManager cloudManager,
                                org.apache.solr.common.cloud.ZkNodeProps message,
                                org.apache.solr.common.cloud.DocCollection collection,
                                org.apache.solr.common.cloud.Slice parentSlice,
                                List<org.apache.solr.common.cloud.DocRouter.Range> subRanges,
                                List<String> subSlices,
                                List<String> subShardNames,
                                boolean firstReplicaNrt)

lockForSplit

public static boolean lockForSplit(org.apache.solr.client.solrj.cloud.SolrCloudManager cloudManager,
                                   String collection,
                                   String shard)
                            throws Exception

Throws:

Exception

unlockForSplit

public static void unlockForSplit(org.apache.solr.client.solrj.cloud.SolrCloudManager cloudManager,
                                  String collection,
                                  String shard)
                           throws Exception

Throws:

Exception