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

Class SplitShardCmd

java.lang.Object

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

All Implemented Interfaces:

OverseerCollectionMessageHandler.Cmd

public class SplitShardCmd
extends Object
implements OverseerCollectionMessageHandler.Cmd

Constructor Summary

Constructors

Constructor	Description
SplitShardCmd(OverseerCollectionMessageHandler ocmh)

Method Summary

Modifier and Type	Method	Description
void	call(ClusterState state, ZkNodeProps message, NamedList results)
static String	fillRanges(SolrCloudManager cloudManager, ZkNodeProps message, DocCollection collection, Slice parentSlice, List<DocRouter.Range> subRanges, List<String> subSlices, List<String> subShardNames, boolean firstReplicaNrt)
static Slice	getParentSlice(ClusterState clusterState, String collectionName, AtomicReference<String> slice, String splitKey)
static boolean	lockForSplit(SolrCloudManager cloudManager, String collection, String shard)
boolean	split(ClusterState clusterState, ZkNodeProps message, NamedList<Object> results)
static void	unlockForSplit(SolrCloudManager cloudManager, String collection, String shard)

Methods inherited from class java.lang.Object

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

Constructor Detail

SplitShardCmd

public SplitShardCmd(OverseerCollectionMessageHandler ocmh)

Method Detail

call

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

Specified by:

call in interface OverseerCollectionMessageHandler.Cmd

Throws:

Exception

split

public boolean split(ClusterState clusterState,
                     ZkNodeProps message,
                     NamedList<Object> results)
              throws Exception

Throws:

Exception

getParentSlice

public static Slice getParentSlice(ClusterState clusterState,
                                   String collectionName,
                                   AtomicReference<String> slice,
                                   String splitKey)

fillRanges

public static String fillRanges(SolrCloudManager cloudManager,
                                ZkNodeProps message,
                                DocCollection collection,
                                Slice parentSlice,
                                List<DocRouter.Range> subRanges,
                                List<String> subSlices,
                                List<String> subShardNames,
                                boolean firstReplicaNrt)

lockForSplit

public static boolean lockForSplit(SolrCloudManager cloudManager,
                                   String collection,
                                   String shard)
                            throws Exception

Throws:

Exception

unlockForSplit

public static void unlockForSplit(SolrCloudManager cloudManager,
                                  String collection,
                                  String shard)
                           throws Exception

Throws:

Exception