org.apache.solr.handler.component

Class HttpShardHandler

java.lang.Object

org.apache.solr.handler.component.ShardHandler

org.apache.solr.handler.component.HttpShardHandler

public class HttpShardHandler
extends ShardHandler

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
private static class	HttpShardHandler.SimpleSolrResponse

Field Summary

Fields

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 Summary

Constructors

Constructor and Description
HttpShardHandler(HttpShardHandlerFactory httpShardHandlerFactory)

Method Summary

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

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Field Detail

httpShardHandlerFactory

private HttpShardHandlerFactory httpShardHandlerFactory

completionService

private java.util.concurrent.CompletionService<ShardResponse> completionService

pending

private java.util.Set<java.util.concurrent.Future<ShardResponse>> pending

shardToURLs

private java.util.Map<java.lang.String,java.util.List<java.lang.String>> shardToURLs

Constructor Detail

HttpShardHandler

public HttpShardHandler(HttpShardHandlerFactory httpShardHandlerFactory)

Method Detail

getURLs

private java.util.List<java.lang.String> getURLs(java.lang.String shard)

submit

public void submit(ShardRequest sreq,
                   java.lang.String shard,
                   ModifiableSolrParams params)

Specified by:

submit in class ShardHandler

takeCompletedOrError

public ShardResponse takeCompletedOrError()

returns a ShardResponse of the last response correlated with a ShardRequest, or immediately returns a ShardResponse if there was an error detected

Specified by:

takeCompletedOrError in class ShardHandler

cancelAll

public void cancelAll()

Specified by:

cancelAll in class ShardHandler

checkDistributed

public void checkDistributed(ResponseBuilder rb)

Specified by:

checkDistributed in class ShardHandler