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.Req |
static class |
SolrCmdDistributor.Response |
static class |
SolrCmdDistributor.RetryNode |
static class |
SolrCmdDistributor.StdNode |
Modifier and Type | Field and Description |
---|---|
static org.slf4j.Logger |
log |
static Diagnostics.Callable |
testing_errorHook |
Constructor and Description |
---|
SolrCmdDistributor(StreamingSolrServers servers,
int maxRetriesOnForward,
int retryPause) |
SolrCmdDistributor(UpdateShardHandler updateShardHandler) |
Modifier and Type | Method and Description |
---|---|
void |
distribAdd(AddUpdateCommand cmd,
List<SolrCmdDistributor.Node> nodes,
ModifiableSolrParams params) |
void |
distribAdd(AddUpdateCommand cmd,
List<SolrCmdDistributor.Node> nodes,
ModifiableSolrParams params,
boolean synchronous) |
void |
distribAdd(AddUpdateCommand cmd,
List<SolrCmdDistributor.Node> nodes,
ModifiableSolrParams params,
boolean synchronous,
DistributedUpdateProcessor.RequestReplicationTracker rrt) |
void |
distribCommit(CommitUpdateCommand cmd,
List<SolrCmdDistributor.Node> nodes,
ModifiableSolrParams params) |
void |
distribDelete(DeleteUpdateCommand cmd,
List<SolrCmdDistributor.Node> nodes,
ModifiableSolrParams params) |
void |
distribDelete(DeleteUpdateCommand cmd,
List<SolrCmdDistributor.Node> nodes,
ModifiableSolrParams params,
boolean sync) |
void |
finish() |
List<SolrCmdDistributor.Error> |
getErrors() |
public static org.slf4j.Logger log
public static Diagnostics.Callable testing_errorHook
public SolrCmdDistributor(UpdateShardHandler updateShardHandler)
public SolrCmdDistributor(StreamingSolrServers servers, int maxRetriesOnForward, int retryPause)
public void finish()
public void distribDelete(DeleteUpdateCommand cmd, List<SolrCmdDistributor.Node> nodes, ModifiableSolrParams params) throws IOException
IOException
public void distribDelete(DeleteUpdateCommand cmd, List<SolrCmdDistributor.Node> nodes, ModifiableSolrParams params, boolean sync) throws IOException
IOException
public void distribAdd(AddUpdateCommand cmd, List<SolrCmdDistributor.Node> nodes, ModifiableSolrParams params) throws IOException
IOException
public void distribAdd(AddUpdateCommand cmd, List<SolrCmdDistributor.Node> nodes, ModifiableSolrParams params, boolean synchronous) throws IOException
IOException
public void distribAdd(AddUpdateCommand cmd, List<SolrCmdDistributor.Node> nodes, ModifiableSolrParams params, boolean synchronous, DistributedUpdateProcessor.RequestReplicationTracker rrt) throws IOException
IOException
public void distribCommit(CommitUpdateCommand cmd, List<SolrCmdDistributor.Node> nodes, ModifiableSolrParams params) throws IOException
IOException
public List<SolrCmdDistributor.Error> getErrors()
Copyright © 2000-2014 Apache Software Foundation. All Rights Reserved.