Class MaintainTimeRoutedAliasCmd
- java.lang.Object
-
- org.apache.solr.cloud.api.collections.MaintainTimeRoutedAliasCmd
-
- All Implemented Interfaces:
OverseerCollectionMessageHandler.Cmd
public class MaintainTimeRoutedAliasCmd extends Object
(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 Description static String
IF_MOST_RECENT_COLL_NAME
-
Constructor Summary
Constructors Constructor Description MaintainTimeRoutedAliasCmd(OverseerCollectionMessageHandler ocmh)
-
Method Summary
All Methods Static Methods Instance Methods Concrete Methods Modifier and Type Method Description void
call(ClusterState clusterState, ZkNodeProps message, NamedList results)
static NamedList
remoteInvoke(CollectionsHandler collHandler, String aliasName, String mostRecentCollName)
Invokes this command from the client.
-
-
-
Field Detail
-
IF_MOST_RECENT_COLL_NAME
public static final String IF_MOST_RECENT_COLL_NAME
- See Also:
- Constant Field Values
-
-
Constructor Detail
-
MaintainTimeRoutedAliasCmd
public MaintainTimeRoutedAliasCmd(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 RoutedAliasUpdateProcessor.- Throws:
Exception
-
call
public void call(ClusterState clusterState, ZkNodeProps message, NamedList results) throws Exception
- Throws:
Exception
-
-