public class Assign extends Object
Modifier and Type | Class and Description |
---|---|
static class |
Assign.AssignmentException
Thrown if there is an exception while assigning nodes for replicas
|
Constructor and Description |
---|
Assign() |
Modifier and Type | Method and Description |
---|---|
static String |
assignCoreNodeName(DistribStateManager stateManager,
DocCollection collection) |
static String |
assignShard(DocCollection collection,
Integer numShards)
Assign a new unique id up to slices count - then add replicas evenly.
|
static String |
buildSolrCoreName(DistribStateManager stateManager,
DocCollection collection,
String shard,
Replica.Type type) |
static String |
buildSolrCoreName(DistribStateManager stateManager,
DocCollection collection,
String shard,
Replica.Type type,
boolean newCollection) |
static String |
buildSolrCoreName(String collectionName,
String shard,
Replica.Type type,
int replicaNum) |
static String |
getCounterNodePath(String collection) |
static List<String> |
getLiveOrLiveAndCreateNodeSetList(Set<String> liveNodes,
ZkNodeProps message,
Random random) |
static List<org.apache.solr.cloud.api.collections.Assign.ReplicaCount> |
getNodesForNewReplicas(ClusterState clusterState,
String collectionName,
String shard,
int nrtReplicas,
Object createNodeSet,
SolrCloudManager cloudManager) |
static List<ReplicaPosition> |
getPositionsUsingPolicy(String collName,
List<String> shardNames,
int nrtReplicas,
int tlogReplicas,
int pullReplicas,
String policyName,
SolrCloudManager cloudManager,
List<String> nodesList) |
static List<ReplicaPosition> |
identifyNodes(SolrCloudManager cloudManager,
ClusterState clusterState,
List<String> nodeList,
String collectionName,
ZkNodeProps message,
List<String> shardNames,
int numNrtReplicas,
int numTlogReplicas,
int numPullReplicas) |
static int |
incAndGetId(DistribStateManager stateManager,
String collection,
int defaultValue) |
public static int incAndGetId(DistribStateManager stateManager, String collection, int defaultValue)
public static String assignCoreNodeName(DistribStateManager stateManager, DocCollection collection)
public static String assignShard(DocCollection collection, Integer numShards)
public static String buildSolrCoreName(String collectionName, String shard, Replica.Type type, int replicaNum)
public static String buildSolrCoreName(DistribStateManager stateManager, DocCollection collection, String shard, Replica.Type type, boolean newCollection)
public static String buildSolrCoreName(DistribStateManager stateManager, DocCollection collection, String shard, Replica.Type type)
public static List<String> getLiveOrLiveAndCreateNodeSetList(Set<String> liveNodes, ZkNodeProps message, Random random)
public static List<ReplicaPosition> identifyNodes(SolrCloudManager cloudManager, ClusterState clusterState, List<String> nodeList, String collectionName, ZkNodeProps message, List<String> shardNames, int numNrtReplicas, int numTlogReplicas, int numPullReplicas) throws IOException, InterruptedException, Assign.AssignmentException
public static List<org.apache.solr.cloud.api.collections.Assign.ReplicaCount> getNodesForNewReplicas(ClusterState clusterState, String collectionName, String shard, int nrtReplicas, Object createNodeSet, SolrCloudManager cloudManager) throws IOException, InterruptedException, Assign.AssignmentException
public static List<ReplicaPosition> getPositionsUsingPolicy(String collName, List<String> shardNames, int nrtReplicas, int tlogReplicas, int pullReplicas, String policyName, SolrCloudManager cloudManager, List<String> nodesList) throws IOException, InterruptedException, Assign.AssignmentException
Copyright © 2000-2018 Apache Software Foundation. All Rights Reserved.