org.apache.solr.update

Class SolrCmdDistributor

java.lang.Object

org.apache.solr.update.SolrCmdDistributor

All Implemented Interfaces:

Closeable, AutoCloseable

public class SolrCmdDistributor
extends Object
implements Closeable

Used for distributing commands from a shard leader to its replicas.

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static interface	SolrCmdDistributor.AbortCheck
static class	SolrCmdDistributor.Error
static class	SolrCmdDistributor.ForwardNode
static class	SolrCmdDistributor.Node
static class	SolrCmdDistributor.Req
static class	SolrCmdDistributor.Response
static class	SolrCmdDistributor.StdNode

Field Summary

Fields

Modifier and Type	Field and Description
static Diagnostics.Callable	testing_errorHook

Constructor Summary

Constructors

Constructor and Description
SolrCmdDistributor(UpdateShardHandler updateShardHandler)

Method Summary

Modifier and Type	Method and Description
void	blockAndDoRetries()
void	close()
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.RollupRequestReplicationTracker rollupTracker, DistributedUpdateProcessor.LeaderRequestReplicationTracker leaderTracker)
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, DistributedUpdateProcessor.RollupRequestReplicationTracker rollupTracker, DistributedUpdateProcessor.LeaderRequestReplicationTracker leaderTracker)
void	finish()
List<SolrCmdDistributor.Error>	getErrors()

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Field Detail

testing_errorHook

public static Diagnostics.Callable testing_errorHook

Constructor Detail

SolrCmdDistributor

public SolrCmdDistributor(UpdateShardHandler updateShardHandler)

Method Detail

finish

public void finish()

close

public void close()

Specified by:

close in interface Closeable

Specified by:

close in interface AutoCloseable

distribDelete

public void distribDelete(DeleteUpdateCommand cmd,
                          List<SolrCmdDistributor.Node> nodes,
                          ModifiableSolrParams params)
                   throws IOException

Throws:

IOException

distribDelete

public void distribDelete(DeleteUpdateCommand cmd,
                          List<SolrCmdDistributor.Node> nodes,
                          ModifiableSolrParams params,
                          boolean sync,
                          DistributedUpdateProcessor.RollupRequestReplicationTracker rollupTracker,
                          DistributedUpdateProcessor.LeaderRequestReplicationTracker leaderTracker)
                   throws IOException

Throws:

IOException

distribAdd

public void distribAdd(AddUpdateCommand cmd,
                       List<SolrCmdDistributor.Node> nodes,
                       ModifiableSolrParams params)
                throws IOException

Throws:

IOException

distribAdd

public void distribAdd(AddUpdateCommand cmd,
                       List<SolrCmdDistributor.Node> nodes,
                       ModifiableSolrParams params,
                       boolean synchronous)
                throws IOException

Throws:

IOException

distribAdd

public void distribAdd(AddUpdateCommand cmd,
                       List<SolrCmdDistributor.Node> nodes,
                       ModifiableSolrParams params,
                       boolean synchronous,
                       DistributedUpdateProcessor.RollupRequestReplicationTracker rollupTracker,
                       DistributedUpdateProcessor.LeaderRequestReplicationTracker leaderTracker)
                throws IOException

Throws:

IOException

distribCommit

public void distribCommit(CommitUpdateCommand cmd,
                          List<SolrCmdDistributor.Node> nodes,
                          ModifiableSolrParams params)
                   throws IOException

Throws:

IOException

blockAndDoRetries

public void blockAndDoRetries()

getErrors

public List<SolrCmdDistributor.Error> getErrors()