public class ClusterStateMutator extends Object
Modifier and Type | Field and Description |
---|---|
protected ZkStateReader |
zkStateReader |
Constructor and Description |
---|
ClusterStateMutator(ZkStateReader zkStateReader) |
Modifier and Type | Method and Description |
---|---|
ZkWriteCommand |
createCollection(ClusterState clusterState,
ZkNodeProps message) |
ZkWriteCommand |
deleteCollection(ClusterState clusterState,
ZkNodeProps message) |
static String |
getAssignedCoreNodeName(ClusterState state,
ZkNodeProps message) |
static String |
getAssignedId(ClusterState state,
String nodeName,
ZkNodeProps coreState) |
static void |
getShardNames(Integer numShards,
List<String> shardNames) |
static void |
getShardNames(List<String> shardNames,
String shards) |
static ClusterState |
newState(ClusterState state,
String name,
DocCollection collection) |
protected final ZkStateReader zkStateReader
public ClusterStateMutator(ZkStateReader zkStateReader)
public ZkWriteCommand createCollection(ClusterState clusterState, ZkNodeProps message)
public ZkWriteCommand deleteCollection(ClusterState clusterState, ZkNodeProps message)
public static ClusterState newState(ClusterState state, String name, DocCollection collection)
public static String getAssignedId(ClusterState state, String nodeName, ZkNodeProps coreState)
public static String getAssignedCoreNodeName(ClusterState state, ZkNodeProps message)
Copyright © 2000-2015 Apache Software Foundation. All Rights Reserved.