public class HttpShardHandler extends ShardHandler
| Modifier and Type | Field and Description |
|---|---|
protected static org.slf4j.Logger |
log |
| Constructor and Description |
|---|
HttpShardHandler(HttpShardHandlerFactory httpShardHandlerFactory,
org.apache.http.client.HttpClient httpClient) |
| Modifier and Type | Method and Description |
|---|---|
void |
cancelAll() |
ShardHandlerFactory |
getShardHandlerFactory() |
protected QueryRequest |
makeQueryRequest(ShardRequest sreq,
ModifiableSolrParams params,
String shard)
Subclasses could modify the request based on the shard
|
void |
prepDistributed(ResponseBuilder rb) |
void |
submit(ShardRequest sreq,
String shard,
ModifiableSolrParams params) |
ShardResponse |
takeCompletedIncludingErrors()
returns a ShardResponse of the last response correlated with a ShardRequest.
|
ShardResponse |
takeCompletedOrError()
returns a ShardResponse of the last response correlated with a ShardRequest,
or immediately returns a ShardResponse if there was an error detected
|
protected ShardResponse |
transfomResponse(ShardRequest sreq,
ShardResponse rsp,
String shard)
Subclasses could modify the Response based on the the shard
|
public HttpShardHandler(HttpShardHandlerFactory httpShardHandlerFactory, org.apache.http.client.HttpClient httpClient)
public void submit(ShardRequest sreq, String shard, ModifiableSolrParams params)
submit in class ShardHandlerprotected QueryRequest makeQueryRequest(ShardRequest sreq, ModifiableSolrParams params, String shard)
protected ShardResponse transfomResponse(ShardRequest sreq, ShardResponse rsp, String shard)
public ShardResponse takeCompletedIncludingErrors()
takeCompletedIncludingErrors in class ShardHandlerpublic ShardResponse takeCompletedOrError()
takeCompletedOrError in class ShardHandlerpublic void cancelAll()
cancelAll in class ShardHandlerpublic void prepDistributed(ResponseBuilder rb)
prepDistributed in class ShardHandlerpublic ShardHandlerFactory getShardHandlerFactory()
getShardHandlerFactory in class ShardHandlerCopyright © 2000-2015 Apache Software Foundation. All Rights Reserved.