org.apache.solr.handler.component

Class HttpShardHandler

java.lang.Object

org.apache.solr.handler.component.ShardHandler

org.apache.solr.handler.component.HttpShardHandler

@SolrThreadUnsafe
public class HttpShardHandler
extends ShardHandler

Field Summary

Fields

Modifier and Type	Field and Description
static String	ONLY_NRT_REPLICAS If the request context map has an entry with this key and Boolean.TRUE as value, prepDistributed(ResponseBuilder) will only include Replica.Type.NRT replicas as possible destination of the distributed request (or a leader replica of type Replica.Type.TLOG).

Constructor Summary

Constructors

Constructor and Description
HttpShardHandler(HttpShardHandlerFactory httpShardHandlerFactory, Http2SolrClient httpClient)

Method Summary

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)
protected NamedList<Object>	request(String url, SolrRequest req)
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

Methods inherited from class java.lang.Object

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

Field Detail

ONLY_NRT_REPLICAS

public static String ONLY_NRT_REPLICAS

If the request context map has an entry with this key and Boolean.TRUE as value, prepDistributed(ResponseBuilder) will only include Replica.Type.NRT replicas as possible destination of the distributed request (or a leader replica of type Replica.Type.TLOG). This is used by the RealtimeGet handler, since other types of replicas shouldn't respond to RTG requests

Constructor Detail

HttpShardHandler

public HttpShardHandler(HttpShardHandlerFactory httpShardHandlerFactory,
                        Http2SolrClient httpClient)

Method Detail

submit

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

Specified by:

submit in class ShardHandler

request

protected NamedList<Object> request(String url,
                                    SolrRequest req)
                             throws IOException,
                                    SolrServerException

Throws:

IOException

SolrServerException

makeQueryRequest

protected QueryRequest makeQueryRequest(ShardRequest sreq,
                                        ModifiableSolrParams params,
                                        String shard)

Subclasses could modify the request based on the shard

transfomResponse

protected ShardResponse transfomResponse(ShardRequest sreq,
                                         ShardResponse rsp,
                                         String shard)

Subclasses could modify the Response based on the the shard

takeCompletedIncludingErrors

public ShardResponse takeCompletedIncludingErrors()

returns a ShardResponse of the last response correlated with a ShardRequest. This won't return early if it runs into an error.

Specified by:

takeCompletedIncludingErrors 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

prepDistributed

public void prepDistributed(ResponseBuilder rb)

Specified by:

prepDistributed in class ShardHandler

getShardHandlerFactory

public ShardHandlerFactory getShardHandlerFactory()

Specified by:

getShardHandlerFactory in class ShardHandler