org.apache.solr.update
Class SolrCmdDistributor

java.lang.Object
  org.apache.solr.update.SolrCmdDistributor

public class SolrCmdDistributor
extends Object

Nested Class Summary

static class	SolrCmdDistributor.Error
static class	SolrCmdDistributor.Node
static class	SolrCmdDistributor.Request
static class	SolrCmdDistributor.Response
static class	SolrCmdDistributor.StdNode

Field Summary

static org.slf4j.Logger

log

Constructor Summary

SolrCmdDistributor()

Method Summary

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

Constructor Detail

SolrCmdDistributor

public SolrCmdDistributor()

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()