Package org.apache.solr.cloud.overseer
Class ClusterStateMutator
- java.lang.Object
-
- org.apache.solr.cloud.overseer.ClusterStateMutator
-
public class ClusterStateMutator extends Object
-
-
Field Summary
Fields Modifier and Type Field Description protected SolrCloudManager
dataProvider
protected DistribStateManager
stateManager
-
Constructor Summary
Constructors Constructor Description ClusterStateMutator(SolrCloudManager dataProvider)
-
Method Summary
All Methods Static Methods Instance Methods Concrete Methods Modifier and Type Method Description ZkWriteCommand
createCollection(ClusterState clusterState, ZkNodeProps message)
ZkWriteCommand
deleteCollection(ClusterState clusterState, ZkNodeProps message)
static String
getAssignedCoreNodeName(DocCollection collection, String forNodeName, String forCoreName)
static String
getAssignedId(DocCollection collection, String nodeName)
static void
getShardNames(Integer numShards, List<String> shardNames)
static void
getShardNames(List<String> shardNames, String shards)
ZkWriteCommand
migrateStateFormat(ClusterState clusterState, ZkNodeProps message)
static ClusterState
newState(ClusterState state, String name, DocCollection collection)
-
-
-
Field Detail
-
dataProvider
protected final SolrCloudManager dataProvider
-
stateManager
protected final DistribStateManager stateManager
-
-
Constructor Detail
-
ClusterStateMutator
public ClusterStateMutator(SolrCloudManager dataProvider)
-
-
Method Detail
-
createCollection
public ZkWriteCommand createCollection(ClusterState clusterState, ZkNodeProps message)
-
deleteCollection
public ZkWriteCommand deleteCollection(ClusterState clusterState, ZkNodeProps message)
-
newState
public static ClusterState newState(ClusterState state, String name, DocCollection collection)
-
getAssignedId
public static String getAssignedId(DocCollection collection, String nodeName)
-
getAssignedCoreNodeName
public static String getAssignedCoreNodeName(DocCollection collection, String forNodeName, String forCoreName)
-
migrateStateFormat
public ZkWriteCommand migrateStateFormat(ClusterState clusterState, ZkNodeProps message)
-
-