Class MirroringUpdateProcessor
- java.lang.Object
-
- org.apache.solr.update.processor.UpdateRequestProcessor
-
- org.apache.solr.crossdc.update.processor.MirroringUpdateProcessor
-
- All Implemented Interfaces:
Closeable,AutoCloseable
public class MirroringUpdateProcessor extends UpdateRequestProcessor
-
-
Field Summary
-
Fields inherited from class org.apache.solr.update.processor.UpdateRequestProcessor
next
-
-
Constructor Summary
Constructors Constructor Description MirroringUpdateProcessor(UpdateRequestProcessor next, boolean doMirroring, boolean indexUnmirrorableDocs, boolean mirrorCommits, CrossDcConf.ExpandDbq expandDbq, long maxMirroringBatchSizeBytes, org.apache.solr.common.params.SolrParams mirroredReqParams, DistributedUpdateProcessor.DistribPhase distribPhase, RequestMirroringHandler requestMirroringHandler, ProducerMetrics producerMetrics)
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description voidfinish()voidprocessAdd(AddUpdateCommand cmd)voidprocessCommit(CommitUpdateCommand cmd)voidprocessDelete(DeleteUpdateCommand cmd)voidprocessRollback(RollbackUpdateCommand cmd)-
Methods inherited from class org.apache.solr.update.processor.UpdateRequestProcessor
close, doClose, processMergeIndexes
-
-
-
-
Constructor Detail
-
MirroringUpdateProcessor
public MirroringUpdateProcessor(UpdateRequestProcessor next, boolean doMirroring, boolean indexUnmirrorableDocs, boolean mirrorCommits, CrossDcConf.ExpandDbq expandDbq, long maxMirroringBatchSizeBytes, org.apache.solr.common.params.SolrParams mirroredReqParams, DistributedUpdateProcessor.DistribPhase distribPhase, RequestMirroringHandler requestMirroringHandler, ProducerMetrics producerMetrics)
-
-
Method Detail
-
processAdd
public void processAdd(AddUpdateCommand cmd) throws IOException
- Overrides:
processAddin classUpdateRequestProcessor- Throws:
IOException
-
processDelete
public void processDelete(DeleteUpdateCommand cmd) throws IOException
- Overrides:
processDeletein classUpdateRequestProcessor- Throws:
IOException
-
processRollback
public void processRollback(RollbackUpdateCommand cmd) throws IOException
- Overrides:
processRollbackin classUpdateRequestProcessor- Throws:
IOException
-
processCommit
public void processCommit(CommitUpdateCommand cmd) throws IOException
- Overrides:
processCommitin classUpdateRequestProcessor- Throws:
IOException
-
finish
public final void finish() throws IOException- Overrides:
finishin classUpdateRequestProcessor- Throws:
IOException
-
-