public class HttpShardHandler extends ShardHandler
Modifier and Type | Class and Description |
---|---|
private static class |
HttpShardHandler.SimpleSolrResponse |
Modifier and Type | Field and Description |
---|---|
private java.util.concurrent.CompletionService<ShardResponse> |
completionService |
private HttpShardHandlerFactory |
httpShardHandlerFactory |
private java.util.Set<java.util.concurrent.Future<ShardResponse>> |
pending |
private java.util.Map<java.lang.String,java.util.List<java.lang.String>> |
shardToURLs |
Constructor and Description |
---|
HttpShardHandler(HttpShardHandlerFactory httpShardHandlerFactory) |
Modifier and Type | Method and Description |
---|---|
void |
cancelAll() |
void |
checkDistributed(ResponseBuilder rb) |
private java.util.List<java.lang.String> |
getURLs(java.lang.String shard) |
void |
submit(ShardRequest sreq,
java.lang.String shard,
ModifiableSolrParams params) |
ShardResponse |
takeCompletedOrError()
returns a ShardResponse of the last response correlated with a ShardRequest,
or immediately returns a ShardResponse if there was an error detected
|
private HttpShardHandlerFactory httpShardHandlerFactory
private java.util.concurrent.CompletionService<ShardResponse> completionService
private java.util.Set<java.util.concurrent.Future<ShardResponse>> pending
private java.util.Map<java.lang.String,java.util.List<java.lang.String>> shardToURLs
public HttpShardHandler(HttpShardHandlerFactory httpShardHandlerFactory)
private java.util.List<java.lang.String> getURLs(java.lang.String shard)
public void submit(ShardRequest sreq, java.lang.String shard, ModifiableSolrParams params)
submit
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