org.apache.solr.cloud

Class ShardRequestProcessor

java.lang.Object

org.apache.solr.cloud.ShardRequestProcessor

public class ShardRequestProcessor
extends Object

This class provides functionality required to invoke operations for Solr collection replicas and process the results of those operations. TODO - Needs to cleanup this class as well as OverseerCollectionMessageHandler

Constructor Summary

Constructors

Constructor and Description
ShardRequestProcessor(ShardHandler shardHandler, String adminPath, ZkStateReader zkStateReader, String asyncId)

Method Summary

Methods

Modifier and Type	Method and Description
ZkStateReader	getZkStateReader()
NamedList	processResponses(boolean abortOnError, String msgOnError, Set<String> okayExceptions)
void	sendShardRequest(String nodeName, ModifiableSolrParams params)

Methods inherited from class java.lang.Object

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

Constructor Detail

ShardRequestProcessor

public ShardRequestProcessor(ShardHandler shardHandler,
                     String adminPath,
                     ZkStateReader zkStateReader,
                     String asyncId)

Method Detail

getZkStateReader

public ZkStateReader getZkStateReader()

sendShardRequest

public void sendShardRequest(String nodeName,
                    ModifiableSolrParams params)

processResponses

public NamedList processResponses(boolean abortOnError,
                         String msgOnError,
                         Set<String> okayExceptions)