public class SplitShardCmd extends Object implements OverseerCollectionMessageHandler.Cmd
Constructor and Description |
---|
SplitShardCmd(OverseerCollectionMessageHandler ocmh) |
Modifier and Type | Method and 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) |
public SplitShardCmd(OverseerCollectionMessageHandler ocmh)
public void call(ClusterState state, ZkNodeProps message, NamedList results) throws Exception
call
in interface OverseerCollectionMessageHandler.Cmd
Exception
public boolean split(ClusterState clusterState, ZkNodeProps message, NamedList<Object> results) throws Exception
Exception
public static Slice getParentSlice(ClusterState clusterState, String collectionName, AtomicReference<String> slice, String splitKey)
public static String fillRanges(SolrCloudManager cloudManager, ZkNodeProps message, DocCollection collection, Slice parentSlice, List<DocRouter.Range> subRanges, List<String> subSlices, List<String> subShardNames, boolean firstReplicaNrt)
public static boolean lockForSplit(SolrCloudManager cloudManager, String collection, String shard) throws Exception
Exception
public static void unlockForSplit(SolrCloudManager cloudManager, String collection, String shard) throws Exception
Exception
Copyright © 2000-2019 Apache Software Foundation. All Rights Reserved.