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

Class MirroringUpdateRequestProcessorFactory

java.lang.Object

org.apache.solr.update.processor.UpdateRequestProcessorFactory

org.apache.solr.crossdc.update.processor.MirroringUpdateRequestProcessorFactory

All Implemented Interfaces:

UpdateRequestProcessorFactory.RunAlways, NamedListInitializedPlugin, SolrCoreAware

public class MirroringUpdateRequestProcessorFactory
extends UpdateRequestProcessorFactory
implements SolrCoreAware, UpdateRequestProcessorFactory.RunAlways

An update processor that works with the UpdateRequestProcessorFactory to mirror update requests by submitting them to a sink that implements a queue producer.

ADDs and DeleteByIDs are mirrored from leader shards and have internal _version_ fields stripped. node.

A single init arg is required, requestMirroringHandler, which specifies the plugin class used for mirroring requests. This class must implement RequestMirroringHandler.

It is recommended to use the DocBasedVersionConstraintsProcessorFactory upstream of this factory to ensure doc consistency between this cluster and the mirror(s).

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
static class	MirroringUpdateRequestProcessorFactory.NoOpUpdateRequestProcessor

Nested classes/interfaces inherited from class org.apache.solr.update.processor.UpdateRequestProcessorFactory

UpdateRequestProcessorFactory.RunAlways

Field Summary

Fields

Modifier and Type	Field	Description
static String	SERVER_SHOULD_MIRROR

Constructor Summary

Constructors

Constructor	Description
MirroringUpdateRequestProcessorFactory()

Method Summary

Modifier and Type	Method	Description
UpdateRequestProcessor	getInstance(SolrQueryRequest req, SolrQueryResponse rsp, UpdateRequestProcessor next)
void	inform(SolrCore core)
void	init(org.apache.solr.common.util.NamedList<?> args)

Methods inherited from class java.lang.Object

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

Field Detail

SERVER_SHOULD_MIRROR

public static final String SERVER_SHOULD_MIRROR

See Also:

Constant Field Values

Constructor Detail

MirroringUpdateRequestProcessorFactory

public MirroringUpdateRequestProcessorFactory()

Method Detail

init

public void init(org.apache.solr.common.util.NamedList<?> args)

Specified by:

init in interface NamedListInitializedPlugin

inform

public void inform(SolrCore core)

Specified by:

inform in interface SolrCoreAware

getInstance

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

Specified by:

getInstance in class UpdateRequestProcessorFactory