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() |
void |
checkDistributed(ResponseBuilder rb) |
ShardHandlerFactory |
getShardHandlerFactory() |
protected QueryRequest |
makeQueryRequest(ShardRequest sreq,
ModifiableSolrParams params,
String shard)
Subclasses could modify the request based on the shard
|
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 ShardHandler
protected QueryRequest makeQueryRequest(ShardRequest sreq, ModifiableSolrParams params, String shard)
protected ShardResponse transfomResponse(ShardRequest sreq, ShardResponse rsp, String shard)
public ShardResponse takeCompletedIncludingErrors()
takeCompletedIncludingErrors
in class ShardHandler
public ShardResponse takeCompletedOrError()
takeCompletedOrError
in class ShardHandler
public void cancelAll()
cancelAll
in class ShardHandler
public void checkDistributed(ResponseBuilder rb)
checkDistributed
in class ShardHandler
public ShardHandlerFactory getShardHandlerFactory()
getShardHandlerFactory
in class ShardHandler
Copyright © 2000-2015 Apache Software Foundation. All Rights Reserved.