Package org.apache.solr.update
Class SolrCmdDistributor.Req
- java.lang.Object
-
- org.apache.solr.update.SolrCmdDistributor.Req
-
- Enclosing class:
- SolrCmdDistributor
public static class SolrCmdDistributor.Req extends Object
-
-
Field Summary
Fields Modifier and Type Field Description UpdateCommand
cmd
SolrCmdDistributor.Node
node
int
retries
boolean
synchronous
org.apache.solr.client.solrj.request.UpdateRequest
uReq
-
Constructor Summary
Constructors Constructor Description Req(UpdateCommand cmd, SolrCmdDistributor.Node node, org.apache.solr.client.solrj.request.UpdateRequest uReq, boolean synchronous)
Req(UpdateCommand cmd, SolrCmdDistributor.Node node, org.apache.solr.client.solrj.request.UpdateRequest uReq, boolean synchronous, DistributedUpdateProcessor.RollupRequestReplicationTracker rollupTracker, DistributedUpdateProcessor.LeaderRequestReplicationTracker leaderTracker)
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description boolean
shouldRetry(SolrCmdDistributor.SolrError err)
String
toString()
void
trackRequestResult(org.eclipse.jetty.client.api.Response resp, InputStream respBody, boolean success)
-
-
-
Field Detail
-
node
public SolrCmdDistributor.Node node
-
uReq
public org.apache.solr.client.solrj.request.UpdateRequest uReq
-
retries
public int retries
-
synchronous
public boolean synchronous
-
cmd
public UpdateCommand cmd
-
-
Constructor Detail
-
Req
public Req(UpdateCommand cmd, SolrCmdDistributor.Node node, org.apache.solr.client.solrj.request.UpdateRequest uReq, boolean synchronous)
-
Req
public Req(UpdateCommand cmd, SolrCmdDistributor.Node node, org.apache.solr.client.solrj.request.UpdateRequest uReq, boolean synchronous, DistributedUpdateProcessor.RollupRequestReplicationTracker rollupTracker, DistributedUpdateProcessor.LeaderRequestReplicationTracker leaderTracker)
-
-
Method Detail
-
shouldRetry
public boolean shouldRetry(SolrCmdDistributor.SolrError err)
- Returns:
- true if this request should be retried after receiving a particular error false otherwise
-
trackRequestResult
public void trackRequestResult(org.eclipse.jetty.client.api.Response resp, InputStream respBody, boolean success)
-
-