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

static class	DistributedUpdateProcessor.DistribPhase Values this processor supports for the DISTRIB_UPDATE_PARAM.
static class	DistributedUpdateProcessor.RetryNode

Field Summary

static String	COMMIT_END_POINT
static org.slf4j.Logger	log
static String	LOG_REPLAY
static String	VERSION_FIELD

Constructor Summary

DistributedUpdateProcessor(SolrQueryRequest req, SolrQueryResponse rsp, UpdateRequestProcessor next)

Method Summary

void	doDeleteByQuery(DeleteUpdateCommand cmd)
void	finish()
static boolean	getNonZkLeaderAssumption(SolrQueryRequest req) Returns a boolean indicating whether or not the caller should behave as if this is the "leader" even when ZooKeeper is not enabled.
static boolean	isAtomicUpdate(AddUpdateCommand cmd) Utility method that examines the SolrInputDocument in an AddUpdateCommand and returns true if the documents contains atomic update instructions.
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

LOG_REPLAY

public static final String LOG_REPLAY

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

isAtomicUpdate

public static boolean isAtomicUpdate(AddUpdateCommand cmd)

Utility method that examines the SolrInputDocument in an AddUpdateCommand and returns true if the documents contains atomic update instructions.

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 whether 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)