public class AddReplicaCmd extends Object implements OverseerCollectionMessageHandler.Cmd
Modifier and Type | Class and Description |
---|---|
static class |
AddReplicaCmd.CreateReplica
A data structure to keep all information required to create a new replica in one place.
|
Modifier and Type | Field and Description |
---|---|
static String |
SKIP_NODE_ASSIGNMENT
When AddReplica is called with this set to true, then we do not try to find node assignments
for the add replica API.
|
Constructor and Description |
---|
AddReplicaCmd(OverseerCollectionMessageHandler ocmh) |
Modifier and Type | Method and Description |
---|---|
static AddReplicaCmd.CreateReplica |
assignReplicaDetails(SolrCloudManager cloudManager,
ClusterState clusterState,
ZkNodeProps message,
ReplicaPosition replicaPosition) |
static List<ReplicaPosition> |
buildReplicaPositions(SolrCloudManager cloudManager,
ClusterState clusterState,
String collectionName,
ZkNodeProps message,
EnumMap<Replica.Type,Integer> replicaTypeVsCount,
AtomicReference<PolicyHelper.SessionWrapper> sessionWrapper) |
void |
call(ClusterState state,
ZkNodeProps message,
NamedList results) |
public static final String SKIP_NODE_ASSIGNMENT
public AddReplicaCmd(OverseerCollectionMessageHandler ocmh)
public void call(ClusterState state, ZkNodeProps message, NamedList results) throws Exception
call
in interface OverseerCollectionMessageHandler.Cmd
Exception
public static AddReplicaCmd.CreateReplica assignReplicaDetails(SolrCloudManager cloudManager, ClusterState clusterState, ZkNodeProps message, ReplicaPosition replicaPosition)
public static List<ReplicaPosition> buildReplicaPositions(SolrCloudManager cloudManager, ClusterState clusterState, String collectionName, ZkNodeProps message, EnumMap<Replica.Type,Integer> replicaTypeVsCount, AtomicReference<PolicyHelper.SessionWrapper> sessionWrapper) throws IOException, InterruptedException
IOException
InterruptedException
Copyright © 2000-2021 Apache Software Foundation. All Rights Reserved.