public class SolrCmdDistributor extends Object
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 |
Modifier and Type | Field and Description |
---|---|
static org.slf4j.Logger |
log |
Constructor and Description |
---|
SolrCmdDistributor(int numHosts,
ThreadPoolExecutor executor) |
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) |
public SolrCmdDistributor(int numHosts, ThreadPoolExecutor executor)
public void finish()
public void distribDelete(DeleteUpdateCommand cmd, List<SolrCmdDistributor.Node> urls, ModifiableSolrParams params) throws IOException
IOException
public void distribAdd(AddUpdateCommand cmd, List<SolrCmdDistributor.Node> nodes, ModifiableSolrParams params) throws IOException
IOException
public void distribCommit(CommitUpdateCommand cmd, List<SolrCmdDistributor.Node> nodes, ModifiableSolrParams params) throws IOException
IOException
public void submit(SolrCmdDistributor.Request sreq)
public SolrCmdDistributor.Response getResponse()
Copyright © 2000-2012 Apache Software Foundation. All Rights Reserved.