public class Assign extends Object
Constructor and Description |
---|
Assign() |
Modifier and Type | Method and Description |
---|---|
static String |
assignNode(DocCollection collection) |
static String |
assignShard(DocCollection collection,
Integer numShards)
Assign a new unique id up to slices count - then add replicas evenly.
|
static String |
buildCoreName(DocCollection collection,
String shard,
Replica.Type type) |
static String |
buildCoreName(String collectionName,
String shard,
Replica.Type type,
int replicaNum) |
static List<String> |
getLiveOrLiveAndCreateNodeSetList(Set<String> liveNodes,
ZkNodeProps message,
Random random) |
static List<org.apache.solr.cloud.Assign.ReplicaCount> |
getNodesForNewReplicas(ClusterState clusterState,
String collectionName,
String shard,
int numberOfNodes,
Object createNodeSet,
CoreContainer cc) |
static List<ReplicaPosition> |
getPositionsUsingPolicy(String collName,
List<String> shardNames,
int numReplicas,
String policyName,
ZkStateReader zkStateReader,
List<String> nodesList) |
static List<ReplicaPosition> |
identifyNodes(Supplier<CoreContainer> coreContainer,
ZkStateReader zkStateReader,
ClusterState clusterState,
List<String> nodeList,
String collectionName,
ZkNodeProps message,
List<String> shardNames,
int numNrtReplicas,
int numTlogReplicas,
int numPullReplicas) |
public static String assignNode(DocCollection collection)
public static String assignShard(DocCollection collection, Integer numShards)
public static String buildCoreName(String collectionName, String shard, Replica.Type type, int replicaNum)
public static String buildCoreName(DocCollection collection, String shard, Replica.Type type)
public static List<String> getLiveOrLiveAndCreateNodeSetList(Set<String> liveNodes, ZkNodeProps message, Random random)
public static List<ReplicaPosition> identifyNodes(Supplier<CoreContainer> coreContainer, ZkStateReader zkStateReader, ClusterState clusterState, List<String> nodeList, String collectionName, ZkNodeProps message, List<String> shardNames, int numNrtReplicas, int numTlogReplicas, int numPullReplicas) throws org.apache.zookeeper.KeeperException, InterruptedException
org.apache.zookeeper.KeeperException
InterruptedException
public static List<org.apache.solr.cloud.Assign.ReplicaCount> getNodesForNewReplicas(ClusterState clusterState, String collectionName, String shard, int numberOfNodes, Object createNodeSet, CoreContainer cc) throws org.apache.zookeeper.KeeperException, InterruptedException
org.apache.zookeeper.KeeperException
InterruptedException
public static List<ReplicaPosition> getPositionsUsingPolicy(String collName, List<String> shardNames, int numReplicas, String policyName, ZkStateReader zkStateReader, List<String> nodesList) throws org.apache.zookeeper.KeeperException, InterruptedException
org.apache.zookeeper.KeeperException
InterruptedException
Copyright © 2000-2017 Apache Software Foundation. All Rights Reserved.