public class SolrCmdDistributor extends Object implements Closeable
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 Diagnostics.Callable |
testing_errorHook |
Constructor and Description |
---|
SolrCmdDistributor(StreamingSolrClients clients,
int maxRetriesOnForward,
int retryPause) |
SolrCmdDistributor(UpdateShardHandler updateShardHandler) |
public static Diagnostics.Callable testing_errorHook
public SolrCmdDistributor(UpdateShardHandler updateShardHandler)
public SolrCmdDistributor(StreamingSolrClients clients, int maxRetriesOnForward, int retryPause)
public void finish()
public void close()
close
in interface Closeable
close
in interface AutoCloseable
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, DistributedUpdateProcessor.RollupRequestReplicationTracker rollupTracker, DistributedUpdateProcessor.LeaderRequestReplicationTracker leaderTracker) 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.RollupRequestReplicationTracker rollupTracker, DistributedUpdateProcessor.LeaderRequestReplicationTracker leaderTracker) throws IOException
IOException
public void distribCommit(CommitUpdateCommand cmd, List<SolrCmdDistributor.Node> nodes, ModifiableSolrParams params) throws IOException
IOException
public void blockAndDoRetries()
public List<SolrCmdDistributor.Error> getErrors()
Copyright © 2000-2018 Apache Software Foundation. All Rights Reserved.