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 voidsendShardRequest(String nodeName, org.apache.solr.common.params.ModifiableSolrParams params, ShardHandler shardHandler)voidsendShardRequest(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)
-
-