org.apache.solr.update
Class SolrCmdDistributor

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

public class SolrCmdDistributor
extends Object


Nested Class Summary
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
static org.slf4j.Logger log
           
static Diagnostics.Callable testing_errorHook
           
 
Constructor Summary
SolrCmdDistributor(int numHosts, UpdateShardHandler updateShardHandler)
           
 
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

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


Copyright © 2000-2013 Apache Software Foundation. All Rights Reserved.