org.apache.solr.cloud.api.collections

Class MaintainRoutedAliasCmd

java.lang.Object

org.apache.solr.cloud.api.collections.MaintainRoutedAliasCmd

All Implemented Interfaces:

OverseerCollectionMessageHandler.Cmd

public class MaintainRoutedAliasCmd
extends Object
implements OverseerCollectionMessageHandler.Cmd

(Internal) For "time routed aliases", both deletes old collections and creates new collections associated with routed aliases. Note: this logic is within an Overseer because we want to leverage the mutual exclusion property afforded by the lock it obtains on the alias name.

Since:

7.3

NOTE: This API is for internal purposes only and might change in incompatible ways in the next release.

Field Summary

Fields

Modifier and Type	Field and Description
static String	IF_MOST_RECENT_COLL_NAME

Constructor Summary

Constructors

Constructor and Description
MaintainRoutedAliasCmd(OverseerCollectionMessageHandler ocmh)

Method Summary

Modifier and Type	Method and Description
void	call(ClusterState clusterState, ZkNodeProps message, NamedList results)
static NamedList	remoteInvoke(CollectionsHandler collHandler, String aliasName, String mostRecentCollName) Invokes this command from the client.

Methods inherited from class java.lang.Object

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

Field Detail

IF_MOST_RECENT_COLL_NAME

public static final String IF_MOST_RECENT_COLL_NAME

See Also:

Constant Field Values

Constructor Detail

MaintainRoutedAliasCmd

public MaintainRoutedAliasCmd(OverseerCollectionMessageHandler ocmh)

Method Detail

remoteInvoke

public static NamedList remoteInvoke(CollectionsHandler collHandler,
                                     String aliasName,
                                     String mostRecentCollName)
                              throws Exception

Invokes this command from the client. If there's a problem it will throw an exception. Please note that is important to never add async to this invocation. This method must block (up to the standard OCP timeout) to prevent large batches of add's from sending a message to the overseer for every document added in TimeRoutedAliasUpdateProcessor.

Throws:

Exception

call

public void call(ClusterState clusterState,
                 ZkNodeProps message,
                 NamedList results)
          throws Exception

Specified by:

call in interface OverseerCollectionMessageHandler.Cmd

Throws:

Exception