org.exoplatform.services.wcm.search

Class FileESMigration

java.lang.Object

org.exoplatform.container.component.BaseComponentPlugin

org.exoplatform.commons.upgrade.UpgradeProductPlugin

org.exoplatform.services.wcm.search.FileESMigration

All Implemented Interfaces:

org.exoplatform.container.component.ComponentPlugin

public class FileESMigration
extends org.exoplatform.commons.upgrade.UpgradeProductPlugin

Upgrade plugin to index all files in Elasticsearch

Field Summary

Fields

Modifier and Type	Field and Description
static String	FILE_ES_INDEXATION_DONE_KEY
static String	FILE_ES_INDEXATION_KEY
static String	FILE_JCR_COLLABORATION_REINDEXATION_DONE_KEY
static String	FILE_JCR_SYSTEM_REINDEXATION_DONE_KEY

Fields inherited from class org.exoplatform.commons.upgrade.UpgradeProductPlugin

asyncUpgradeExecution, executeOnlyOnce, OLD_PRODUCT_GROUP_ID, oldProductGroupId, PRODUCT_GROUP_ID, productGroupId, targetVersion, UPGRADE_COMPLETED_STATUS, UPGRADE_PLUGIN_ASYNC, UPGRADE_PLUGIN_ENABLE, UPGRADE_PLUGIN_EXECUTE_ONCE_PARAMETER, UPGRADE_PLUGIN_EXECUTION_ORDER, UPGRADE_PLUGIN_TARGET_PARAMETER

Fields inherited from class org.exoplatform.container.component.BaseComponentPlugin

desc, name

Constructor Summary

Constructors

Constructor and Description

FileESMigration(org.exoplatform.container.xml.InitParams initParams, org.exoplatform.commons.search.index.IndexingService indexingService, org.exoplatform.commons.api.settings.SettingService settingService, org.exoplatform.services.jcr.RepositoryService repositoryService, org.exoplatform.commons.search.index.IndexingOperationProcessor indexingOperationProcessor, org.exoplatform.services.scheduler.JobSchedulerService jobSchedulerService)

Method Summary

Modifier and Type	Method and Description
void	indexInES() Run the reindex all operation to fill the indexing queue with all files to index.
void	processIndexation()
void	processUpgrade(String oldVersion, String newVersion)
void	reindexJCR()
boolean	shouldProceedToUpgrade(String newVersion, String previousVersion)

Methods inherited from class org.exoplatform.commons.upgrade.UpgradeProductPlugin

afterUpgrade, beforeUpgrade, equals, getPluginExecutionOrder, getProductGroupId, getTargetVersion, getValue, hashCode, isAsyncUpgradeExecution, isEnabled, isExecuteOnlyOnce, shouldProceedToUpgrade, storeValueForPlugin

Methods inherited from class org.exoplatform.container.component.BaseComponentPlugin

getDescription, getName, setDescription, setName

Methods inherited from class java.lang.Object

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

Field Detail

FILE_ES_INDEXATION_KEY

public static final String FILE_ES_INDEXATION_KEY

See Also:

Constant Field Values

FILE_ES_INDEXATION_DONE_KEY

public static final String FILE_ES_INDEXATION_DONE_KEY

See Also:

Constant Field Values

FILE_JCR_COLLABORATION_REINDEXATION_DONE_KEY

public static final String FILE_JCR_COLLABORATION_REINDEXATION_DONE_KEY

See Also:

Constant Field Values

FILE_JCR_SYSTEM_REINDEXATION_DONE_KEY

public static final String FILE_JCR_SYSTEM_REINDEXATION_DONE_KEY

See Also:

Constant Field Values

Constructor Detail

FileESMigration

public FileESMigration(org.exoplatform.container.xml.InitParams initParams,
                       org.exoplatform.commons.search.index.IndexingService indexingService,
                       org.exoplatform.commons.api.settings.SettingService settingService,
                       org.exoplatform.services.jcr.RepositoryService repositoryService,
                       org.exoplatform.commons.search.index.IndexingOperationProcessor indexingOperationProcessor,
                       org.exoplatform.services.scheduler.JobSchedulerService jobSchedulerService)

Method Detail

processUpgrade

public void processUpgrade(String oldVersion,
                           String newVersion)

Specified by:

processUpgrade in class org.exoplatform.commons.upgrade.UpgradeProductPlugin

shouldProceedToUpgrade

public boolean shouldProceedToUpgrade(String newVersion,
                                      String previousVersion)

Overrides:

shouldProceedToUpgrade in class org.exoplatform.commons.upgrade.UpgradeProductPlugin

reindexJCR

public void reindexJCR()
                throws Exception

Throws:

Exception

indexInES

public void indexInES()
               throws Exception

Run the reindex all operation to fill the indexing queue with all files to index. ESBulkIndexer job is disabled and indexing queue processing (process()) is done synchronously to make sure the flag is set only when it is really done (allow to redo it in case of interruption), and also to make sur JCR reindexing is not launch during this operation (which will impact it since the reindex all operation use the JCR query manager to get all files).

Throws:

Exception

processIndexation

public void processIndexation()