org.apache.solr.update
Class SolrCmdDistributor
java.lang.Object
org.apache.solr.update.SolrCmdDistributor
public class SolrCmdDistributor
- extends Object
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)
|
void |
syncAdd(AddUpdateCommand cmd,
SolrCmdDistributor.Node node,
ModifiableSolrParams params)
Synchronous (blocking) add to specified node. |
void |
syncDelete(DeleteUpdateCommand cmd,
List<SolrCmdDistributor.Node> nodes,
ModifiableSolrParams params)
|
Methods inherited from class java.lang.Object |
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait |
log
public static org.slf4j.Logger log
testing_errorHook
public static Diagnostics.Callable testing_errorHook
SolrCmdDistributor
public SolrCmdDistributor(int numHosts,
UpdateShardHandler updateShardHandler)
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
syncAdd
public void syncAdd(AddUpdateCommand cmd,
SolrCmdDistributor.Node node,
ModifiableSolrParams params)
throws IOException
- Synchronous (blocking) add to specified node. Any error returned from node is propagated.
- Throws:
IOException
syncDelete
public void syncDelete(DeleteUpdateCommand 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.