org.apache.solr.update

Class SolrCmdDistributor

java.lang.Object

org.apache.solr.update.SolrCmdDistributor

public class SolrCmdDistributor
extends Object

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static interface	SolrCmdDistributor.AbortCheck
static class	SolrCmdDistributor.Error
static class	SolrCmdDistributor.Node
static class	SolrCmdDistributor.Request
static class	SolrCmdDistributor.Response
static class	SolrCmdDistributor.StdNode

Field Summary

Fields

Modifier and Type	Field and Description
static org.slf4j.Logger	log
static Diagnostics.Callable	testing_errorHook

Constructor Summary

Constructors

Constructor and Description
SolrCmdDistributor(int numHosts, UpdateShardHandler updateShardHandler)

Method Summary

Methods

Modifier and Type	Method and Description
void	distribAdd(AddUpdateCommand cmd, List<SolrCmdDistributor.Node> nodes, ModifiableSolrParams params)
void	distribCommit(CommitUpdateCommand cmd, List<SolrCmdDistributor.Node> nodes, ModifiableSolrParams params)
void	distribDelete(DeleteUpdateCommand cmd, List<SolrCmdDistributor.Node> urls, ModifiableSolrParams params)
void	finish()
SolrCmdDistributor.Response	getResponse()
void	submit(SolrCmdDistributor.Request sreq)

Methods inherited from class java.lang.Object

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

Field Detail

log

public static org.slf4j.Logger log

testing_errorHook

public static Diagnostics.Callable testing_errorHook

Constructor Detail

SolrCmdDistributor

public SolrCmdDistributor(int numHosts,
                  UpdateShardHandler updateShardHandler)

Method Detail

finish

public void finish()

distribDelete

public void distribDelete(DeleteUpdateCommand cmd,
                 List<SolrCmdDistributor.Node> urls,
                 ModifiableSolrParams params)
                   throws IOException

Throws:

IOException

distribAdd

public void distribAdd(AddUpdateCommand cmd,
              List<SolrCmdDistributor.Node> nodes,
              ModifiableSolrParams params)
                throws IOException

Throws:

IOException

distribCommit

public void distribCommit(CommitUpdateCommand cmd,
                 List<SolrCmdDistributor.Node> nodes,
                 ModifiableSolrParams params)
                   throws IOException

Throws:

IOException

submit

public void submit(SolrCmdDistributor.Request sreq)

getResponse

public SolrCmdDistributor.Response getResponse()