org.alfresco.solr

Class AlfrescoCoreAdminHandler

java.lang.Object

org.apache.solr.handler.RequestHandlerBase

org.apache.solr.handler.admin.CoreAdminHandler

org.alfresco.solr.AlfrescoCoreAdminHandler

All Implemented Interfaces:

org.apache.solr.api.ApiSupport, org.apache.solr.core.SolrInfoMBean, org.apache.solr.handler.NestedRequestHandler, org.apache.solr.metrics.SolrMetricProducer, org.apache.solr.request.SolrRequestHandler, org.apache.solr.security.PermissionNameProvider

public class AlfrescoCoreAdminHandler
extends org.apache.solr.handler.admin.CoreAdminHandler

Nested Class Summary

Nested classes/interfaces inherited from class org.apache.solr.handler.admin.CoreAdminHandler

org.apache.solr.handler.admin.CoreAdminHandler.Invocable

Nested classes/interfaces inherited from interface org.apache.solr.security.PermissionNameProvider

org.apache.solr.security.PermissionNameProvider.Name

Nested classes/interfaces inherited from interface org.apache.solr.core.SolrInfoMBean

org.apache.solr.core.SolrInfoMBean.Category, org.apache.solr.core.SolrInfoMBean.Group

Field Summary

Fields

Modifier and Type	Field and Description
protected static String	ACL_TX_IN_INDEX_NOT_IN_DB
protected static String	ACTION_ACL_CHANGE_SET_TO_REINDEX
protected static String	ACTION_ERROR_MESSAGE_LABEL
protected static String	ACTION_STATUS_LABEL
protected static String	ACTION_STATUS_SCHEDULED
protected static String	ACTION_TX_TO_REINDEX
static String	ALFRESCO_DEFAULTS
static String	DATA_DIR_ROOT
static String	DEFAULT_TEMPLATE
protected static String	DRY_RUN_PARAMETER_NAME
protected static String	DUPLICATED_ACL_TX_IN_INDEX
protected static String	DUPLICATED_TX_IN_INDEX
protected static String	FROM_TX_COMMIT_TIME_PARAMETER_NAME
protected static org.slf4j.Logger	LOGGER
protected static String	MAX_TRANSACTIONS_TO_SCHEDULE_CONF_PROPERTY_NAME
protected static String	MAX_TRANSACTIONS_TO_SCHEDULE_PARAMETER_NAME
protected static String	MISSING_ACL_TX_IN_INDEX
protected static String	MISSING_TX_IN_INDEX
protected static String	TO_TX_COMMIT_TIME_PARAMETER_NAME
protected static String	TX_IN_INDEX_NOT_IN_DB

Fields inherited from class org.apache.solr.handler.admin.CoreAdminHandler

COMPLETED, coreContainer, FAILED, MAX_TRACKED_REQUESTS, parallelExecutor, paramToProp, requestStatusMap, RESPONSE, RESPONSE_MESSAGE, RESPONSE_STATUS, RUNNING

Fields inherited from class org.apache.solr.handler.RequestHandlerBase

appends, defaults, httpCaching, initArgs, invariants

Fields inherited from interface org.apache.solr.security.PermissionNameProvider

ANY, NULL, values

Fields inherited from interface org.apache.solr.request.SolrRequestHandler

TYPE

Constructor Summary

Constructors

Constructor and Description
AlfrescoCoreAdminHandler()
AlfrescoCoreAdminHandler(org.apache.solr.core.CoreContainer coreContainer)

Method Summary

Modifier and Type	Method and Description
protected org.apache.solr.common.util.NamedList<Object>	actionFIX(org.apache.solr.common.params.SolrParams params) Find transactions and acls missing or duplicated in the cores and add them to be reindexed on the next maintenance operation performed by MetadataTracker and AclTracker.
ConcurrentHashMap<String,InformationServer>	getInformationServers()
SolrTrackerScheduler	getScheduler()
TrackerRegistry	getTrackerRegistry()
protected void	handleCustomAction(org.apache.solr.request.SolrQueryRequest req, org.apache.solr.response.SolrQueryResponse rsp)
boolean	hasAlfrescoCore(Collection<org.apache.solr.core.SolrCore> cores) Tests to see if one of the cores is an Alfresco special core!
protected boolean	newCore(String coreName, int numShards, org.alfresco.service.cmr.repository.StoreRef storeRef, String templateName, int replicationFactor, int nodeInstance, int numNodes, String shardIds, Properties extraProperties, org.apache.solr.response.SolrQueryResponse rsp)
protected boolean	newDefaultCore(String coreName, org.alfresco.service.cmr.repository.StoreRef storeRef, String templateName, Properties extraProperties, org.apache.solr.response.SolrQueryResponse rsp)
protected void	setTrackerRegistry(TrackerRegistry trackerRegistry)
protected void	setupNewDefaultCores(String createDefaultCores) Creates new default cores based on the "createDefaultCores" String passed in
void	shutdown() Shutsdown services that exist outside of the core.
void	startup(org.apache.solr.core.CoreContainer coreContainer) Startup services that exist outside of the core.

Methods inherited from class org.apache.solr.handler.admin.CoreAdminHandler

buildCoreParams, getApis, getCategory, getCoreContainer, getDescription, getPermissionName, handleRequestBody, init, initializeMetrics, normalizePath, params, registerV2

Methods inherited from class org.apache.solr.handler.RequestHandlerBase

getDocs, getInitArgs, getName, getPluginInfo, getRequestHandler, getSolrParamsFromNamedList, getSource, getStatistics, getSubHandler, getVersion, handleRequest, setPluginInfo

Methods inherited from class java.lang.Object

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

Methods inherited from interface org.apache.solr.api.ApiSupport

registerV1

Field Detail

LOGGER

protected static final org.slf4j.Logger LOGGER

DATA_DIR_ROOT

public static final String DATA_DIR_ROOT

See Also:

Constant Field Values

ALFRESCO_DEFAULTS

public static final String ALFRESCO_DEFAULTS

See Also:

Constant Field Values

DEFAULT_TEMPLATE

public static final String DEFAULT_TEMPLATE

See Also:

Constant Field Values

ACTION_STATUS_SCHEDULED

protected static final String ACTION_STATUS_SCHEDULED

See Also:

Constant Field Values

DRY_RUN_PARAMETER_NAME

protected static final String DRY_RUN_PARAMETER_NAME

See Also:

Constant Field Values

FROM_TX_COMMIT_TIME_PARAMETER_NAME

protected static final String FROM_TX_COMMIT_TIME_PARAMETER_NAME

See Also:

Constant Field Values

TO_TX_COMMIT_TIME_PARAMETER_NAME

protected static final String TO_TX_COMMIT_TIME_PARAMETER_NAME

See Also:

Constant Field Values

MAX_TRANSACTIONS_TO_SCHEDULE_PARAMETER_NAME

protected static final String MAX_TRANSACTIONS_TO_SCHEDULE_PARAMETER_NAME

See Also:

Constant Field Values

MAX_TRANSACTIONS_TO_SCHEDULE_CONF_PROPERTY_NAME

protected static final String MAX_TRANSACTIONS_TO_SCHEDULE_CONF_PROPERTY_NAME

See Also:

Constant Field Values

TX_IN_INDEX_NOT_IN_DB

protected static final String TX_IN_INDEX_NOT_IN_DB

See Also:

Constant Field Values

DUPLICATED_TX_IN_INDEX

protected static final String DUPLICATED_TX_IN_INDEX

See Also:

Constant Field Values

MISSING_TX_IN_INDEX

protected static final String MISSING_TX_IN_INDEX

See Also:

Constant Field Values

ACL_TX_IN_INDEX_NOT_IN_DB

protected static final String ACL_TX_IN_INDEX_NOT_IN_DB

See Also:

Constant Field Values

DUPLICATED_ACL_TX_IN_INDEX

protected static final String DUPLICATED_ACL_TX_IN_INDEX

See Also:

Constant Field Values

MISSING_ACL_TX_IN_INDEX

protected static final String MISSING_ACL_TX_IN_INDEX

See Also:

Constant Field Values

ACTION_STATUS_LABEL

protected static final String ACTION_STATUS_LABEL

See Also:

Constant Field Values

ACTION_ERROR_MESSAGE_LABEL

protected static final String ACTION_ERROR_MESSAGE_LABEL

See Also:

Constant Field Values

ACTION_TX_TO_REINDEX

protected static final String ACTION_TX_TO_REINDEX

See Also:

Constant Field Values

ACTION_ACL_CHANGE_SET_TO_REINDEX

protected static final String ACTION_ACL_CHANGE_SET_TO_REINDEX

See Also:

Constant Field Values

Constructor Detail

AlfrescoCoreAdminHandler

public AlfrescoCoreAdminHandler()

AlfrescoCoreAdminHandler

public AlfrescoCoreAdminHandler(org.apache.solr.core.CoreContainer coreContainer)

Method Detail

startup

public void startup(org.apache.solr.core.CoreContainer coreContainer)

Startup services that exist outside of the core.

setupNewDefaultCores

protected void setupNewDefaultCores(String createDefaultCores)

Creates new default cores based on the "createDefaultCores" String passed in

Parameters:

createDefaultCores - comma delimited list of corenames.

shutdown

public void shutdown()

Shutsdown services that exist outside of the core.

Overrides:

shutdown in class org.apache.solr.handler.admin.CoreAdminHandler

handleCustomAction

protected void handleCustomAction(org.apache.solr.request.SolrQueryRequest req,
                                  org.apache.solr.response.SolrQueryResponse rsp)

Overrides:

handleCustomAction in class org.apache.solr.handler.admin.CoreAdminHandler

newDefaultCore

protected boolean newDefaultCore(String coreName,
                                 org.alfresco.service.cmr.repository.StoreRef storeRef,
                                 String templateName,
                                 Properties extraProperties,
                                 org.apache.solr.response.SolrQueryResponse rsp)

newCore

protected boolean newCore(String coreName,
                          int numShards,
                          org.alfresco.service.cmr.repository.StoreRef storeRef,
                          String templateName,
                          int replicationFactor,
                          int nodeInstance,
                          int numNodes,
                          String shardIds,
                          Properties extraProperties,
                          org.apache.solr.response.SolrQueryResponse rsp)

hasAlfrescoCore

public boolean hasAlfrescoCore(Collection<org.apache.solr.core.SolrCore> cores)

Tests to see if one of the cores is an Alfresco special core!

Parameters:

cores -

Returns:

actionFIX

protected org.apache.solr.common.util.NamedList<Object> actionFIX(org.apache.solr.common.params.SolrParams params)
                                                           throws org.json.JSONException

Find transactions and acls missing or duplicated in the cores and add them to be reindexed on the next maintenance operation performed by MetadataTracker and AclTracker. Asynchronous execution

Parameters:

params - - core, optional: The name of the SOLR Core

Returns:

The action results: - action.status: scheduled, as it will be executed by Trackers on the next maintenance operation - txToReindex: list of Transaction Ids that are going to be reindexed - aclChangeSetToReindex: list of ACL Change Set Ids that are going to be reindexed

Throws:

org.json.JSONException

getInformationServers

public ConcurrentHashMap<String,InformationServer> getInformationServers()

getTrackerRegistry

public TrackerRegistry getTrackerRegistry()

setTrackerRegistry

protected void setTrackerRegistry(TrackerRegistry trackerRegistry)

getScheduler

public SolrTrackerScheduler getScheduler()