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
Methods inherited from class java.lang.Object |
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait |
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
DistributedUpdateProcessor
public DistributedUpdateProcessor(SolrQueryRequest req,
SolrQueryResponse rsp,
UpdateRequestProcessor next)
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)
Copyright © 2000-2012 Apache Software Foundation. All Rights Reserved.