Package org.apache.solr.crossdc.update.processor

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

Modifier and Type	Method	Description
void	finish()
void	processAdd(AddUpdateCommand cmd)
void	processCommit(CommitUpdateCommand cmd)
void	processDelete(DeleteUpdateCommand cmd)
void	processRollback(RollbackUpdateCommand cmd)

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

close, doClose, processMergeIndexes

Methods inherited from class java.lang.Object

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

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:

processAdd in class UpdateRequestProcessor

Throws:

IOException

processDelete

public void processDelete(DeleteUpdateCommand cmd)
                   throws IOException

Overrides:

processDelete in class UpdateRequestProcessor

Throws:

IOException

processRollback

public void processRollback(RollbackUpdateCommand cmd)
                     throws IOException

Overrides:

processRollback in class UpdateRequestProcessor

Throws:

IOException

processCommit

public void processCommit(CommitUpdateCommand cmd)
                   throws IOException

Overrides:

processCommit in class UpdateRequestProcessor

Throws:

IOException

finish

public final void finish()
                  throws IOException

Overrides:

finish in class UpdateRequestProcessor

Throws:

IOException