org.apache.solr.update.processor

Class TimeRoutedAliasUpdateProcessor

java.lang.Object

org.apache.solr.update.processor.UpdateRequestProcessor

org.apache.solr.update.processor.TimeRoutedAliasUpdateProcessor

All Implemented Interfaces:

Closeable, AutoCloseable

public class TimeRoutedAliasUpdateProcessor
extends UpdateRequestProcessor

Distributes update requests to rolling series of collections partitioned by a timestamp field. Depends on this core having a special core property that points to the alias name that this collection is a part of. And further requires certain metadata on the Alias.

Since:

7.2.0

Field Summary

Fields

Modifier and Type	Field and Description
static String	ALIAS_DISTRIB_UPDATE_PARAM
static String	ROUTER_FIELD_METADATA
static String	TIME_PARTITION_ALIAS_NAME_CORE_PROP

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

next

Constructor Summary

Constructors

Modifier	Constructor and Description
protected	TimeRoutedAliasUpdateProcessor(SolrQueryRequest req, SolrQueryResponse rsp, UpdateRequestProcessor next, String aliasName, DistributedUpdateProcessor.DistribPhase aliasDistribPhase)

Method Summary

Modifier and Type	Method and Description
protected void	doClose() Override to implement resource release logic that *must* be called at the end of a request.
protected String	findTargetCollectionGivenRouteKey(Object routeKey)
void	finish()
void	processAdd(AddUpdateCommand cmd)
void	processCommit(CommitUpdateCommand cmd)
void	processDelete(DeleteUpdateCommand cmd)
static UpdateRequestProcessor	wrap(SolrQueryRequest req, SolrQueryResponse rsp, UpdateRequestProcessor next)

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

close, processMergeIndexes, processRollback

Methods inherited from class java.lang.Object

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

Field Detail

ALIAS_DISTRIB_UPDATE_PARAM

public static final String ALIAS_DISTRIB_UPDATE_PARAM

See Also:

Constant Field Values

TIME_PARTITION_ALIAS_NAME_CORE_PROP

public static final String TIME_PARTITION_ALIAS_NAME_CORE_PROP

See Also:

Constant Field Values

ROUTER_FIELD_METADATA

public static final String ROUTER_FIELD_METADATA

See Also:

Constant Field Values

Constructor Detail

TimeRoutedAliasUpdateProcessor

protected TimeRoutedAliasUpdateProcessor(SolrQueryRequest req,
                                         SolrQueryResponse rsp,
                                         UpdateRequestProcessor next,
                                         String aliasName,
                                         DistributedUpdateProcessor.DistribPhase aliasDistribPhase)

Method Detail

wrap

public static UpdateRequestProcessor wrap(SolrQueryRequest req,
                                          SolrQueryResponse rsp,
                                          UpdateRequestProcessor next)

processAdd

public void processAdd(AddUpdateCommand cmd)
                throws IOException

Overrides:

processAdd in class UpdateRequestProcessor

Throws:

IOException

findTargetCollectionGivenRouteKey

protected String findTargetCollectionGivenRouteKey(Object routeKey)

processDelete

public void processDelete(DeleteUpdateCommand cmd)
                   throws IOException

Overrides:

processDelete in class UpdateRequestProcessor

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

doClose

protected void doClose()

Description copied from class: UpdateRequestProcessor

Override to implement resource release logic that *must* be called at the end of a request.

Overrides:

doClose in class UpdateRequestProcessor