org.apache.solr.update.processor

Class DistributedUpdateProcessor

java.lang.Object

org.apache.solr.update.processor.UpdateRequestProcessor

org.apache.solr.update.processor.DistributedUpdateProcessor

public class DistributedUpdateProcessor
extends UpdateRequestProcessor

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static class	DistributedUpdateProcessor.DistribPhase Values this processor supports for the DISTRIB_UPDATE_PARAM.
static class	DistributedUpdateProcessor.RetryNode

Field Summary

Fields

Modifier and Type	Field and Description
static String	COMMIT_END_POINT
static org.slf4j.Logger	log
static String	VERSION_FIELD

Constructor Summary

Constructors

Constructor and Description
DistributedUpdateProcessor(SolrQueryRequest req, SolrQueryResponse rsp, UpdateRequestProcessor next)

Method Summary

Methods

Modifier and Type	Method and Description
void	doDeleteByQuery(DeleteUpdateCommand cmd)
void	finish()
static boolean	getNonZkLeaderAssumption(SolrQueryRequest req) Returns a boolean indicating wether or not the caller should behave as if this is the "leader" even when ZooKeeper is not enabled.
void	processAdd(AddUpdateCommand cmd)
void	processCommit(CommitUpdateCommand cmd)
void	processDelete(DeleteUpdateCommand cmd)

Methods inherited from class org.apache.solr.update.processor.UpdateRequestProcessor

processMergeIndexes, processRollback

Methods inherited from class java.lang.Object

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

Field Detail

log

public static final org.slf4j.Logger log

COMMIT_END_POINT

public static final String COMMIT_END_POINT

See Also:

Constant Field Values

VERSION_FIELD

public static final String VERSION_FIELD

See Also:

Constant Field Values

Constructor Detail

DistributedUpdateProcessor

public DistributedUpdateProcessor(SolrQueryRequest req,
                          SolrQueryResponse rsp,
                          UpdateRequestProcessor next)

Method Detail

processAdd

public void processAdd(AddUpdateCommand cmd)
                throws IOException

Overrides:

processAdd in class UpdateRequestProcessor

Throws:

IOException

processDelete

public void processDelete(DeleteUpdateCommand cmd)
                   throws IOException

Overrides:

processDelete in class UpdateRequestProcessor

Throws:

IOException

doDeleteByQuery

public void doDeleteByQuery(DeleteUpdateCommand cmd)
                     throws IOException

Throws:

IOException

processCommit

public void processCommit(CommitUpdateCommand cmd)
                   throws IOException

Overrides:

processCommit in class UpdateRequestProcessor

Throws:

IOException

finish

public void finish()
            throws IOException

Overrides:

finish in class UpdateRequestProcessor

Throws:

IOException

getNonZkLeaderAssumption

public static boolean getNonZkLeaderAssumption(SolrQueryRequest req)

Returns a boolean indicating wether or not the caller should behave as if this is the "leader" even when ZooKeeper is not enabled. (Even in non zk mode, tests may simulate updates to/from a leader)