Class CollectionHandlingUtils.ShardRequestTracker
- java.lang.Object
-
- org.apache.solr.cloud.api.collections.CollectionHandlingUtils.ShardRequestTracker
-
- Enclosing class:
- CollectionHandlingUtils
public static class CollectionHandlingUtils.ShardRequestTracker extends Object
-
-
Constructor Summary
Constructors Constructor Description ShardRequestTracker(String asyncId, String adminPath, org.apache.solr.common.cloud.ZkStateReader zkStateReader, ShardHandlerFactory shardHandlerFactory)
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description void
sendShardRequest(String nodeName, org.apache.solr.common.params.ModifiableSolrParams params, ShardHandler shardHandler)
void
sendShardRequest(String nodeName, org.apache.solr.common.params.ModifiableSolrParams params, ShardHandler shardHandler, String adminPath, org.apache.solr.common.cloud.ZkStateReader zkStateReader)
List<org.apache.solr.common.cloud.Replica>
sliceCmd(org.apache.solr.common.cloud.ClusterState clusterState, org.apache.solr.common.params.ModifiableSolrParams params, org.apache.solr.common.cloud.Replica.State stateMatcher, org.apache.solr.common.cloud.Slice slice, ShardHandler shardHandler)
Send request to all replicas of a slice
-
-
-
Constructor Detail
-
ShardRequestTracker
public ShardRequestTracker(String asyncId, String adminPath, org.apache.solr.common.cloud.ZkStateReader zkStateReader, ShardHandlerFactory shardHandlerFactory)
-
-
Method Detail
-
sliceCmd
public List<org.apache.solr.common.cloud.Replica> sliceCmd(org.apache.solr.common.cloud.ClusterState clusterState, org.apache.solr.common.params.ModifiableSolrParams params, org.apache.solr.common.cloud.Replica.State stateMatcher, org.apache.solr.common.cloud.Slice slice, ShardHandler shardHandler)
Send request to all replicas of a slice- Returns:
- List of replicas which is not live for receiving the request
-
sendShardRequest
public void sendShardRequest(String nodeName, org.apache.solr.common.params.ModifiableSolrParams params, ShardHandler shardHandler)
-
sendShardRequest
public void sendShardRequest(String nodeName, org.apache.solr.common.params.ModifiableSolrParams params, ShardHandler shardHandler, String adminPath, org.apache.solr.common.cloud.ZkStateReader zkStateReader)
-
-