com.flowable.indexing

Class ReindexManagerImpl

java.lang.Object

com.flowable.indexing.ReindexManagerImpl

All Implemented Interfaces:

ReindexManager

public class ReindexManagerImpl
extends Object
implements ReindexManager

Field Summary

Fields

Modifier and Type	Field and Description
protected ElasticsearchClient	elasticsearchClient
protected IndexManager	indexManager
protected org.flowable.engine.ProcessEngineConfiguration	processEngineConfiguration
protected ReindexingProperties	reindexingProperties

Constructor Summary

Constructors

Constructor and Description
ReindexManagerImpl(IndexManager indexManager, ElasticsearchClient elasticsearchClient, ReindexingProperties reindexingProperties)

Method Summary

Modifier and Type	Method and Description
org.flowable.engine.ProcessEngineConfiguration	getProcessEngineConfiguration()
void	reindex(String alias, Collection<ReindexEntityPageHandler> reindexEntityPageHandlers) Uses ReindexEntityPageHandler(s) to reindex data, page by page.
void	reindex(String alias, ReindexRunnable reindexRunnable) Executes the provided ReindexRunnable (containing the actual reindex logic), while taking care before and after the execution to properly housekeep the indices: 1.
void	setProcessEngineConfiguration(org.flowable.engine.ProcessEngineConfiguration processEngineConfiguration)
protected boolean	waitForIndexJobsToBeProcessed()

Methods inherited from class java.lang.Object

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

Methods inherited from interface com.flowable.indexing.ReindexManager

reindex

Field Detail

indexManager

protected IndexManager indexManager

reindexingProperties

protected ReindexingProperties reindexingProperties

elasticsearchClient

protected ElasticsearchClient elasticsearchClient

processEngineConfiguration

protected org.flowable.engine.ProcessEngineConfiguration processEngineConfiguration

Constructor Detail

ReindexManagerImpl

public ReindexManagerImpl(IndexManager indexManager,
                          ElasticsearchClient elasticsearchClient,
                          ReindexingProperties reindexingProperties)

Method Detail

reindex

public void reindex(String alias,
                    ReindexRunnable reindexRunnable)

Description copied from interface: ReindexManager

Executes the provided ReindexRunnable (containing the actual reindex logic), while taking care before and after the execution to properly housekeep the indices: 1. String originalIndexName = getTheRealIndexName 2. Delete the alias for the index 3. create a new index (with prefix) 4. Execute custom reindex logic 5. Delete the original index Uses a generic ReindexRunnable that can contain any logic.

Specified by:

reindex in interface ReindexManager

reindex

public void reindex(String alias,
                    Collection<ReindexEntityPageHandler> reindexEntityPageHandlers)

Description copied from interface: ReindexManager

Uses ReindexEntityPageHandler(s) to reindex data, page by page. Internally, a new ReindexRunnable will be created and the ReindexManager.reindex(String, ReindexRunnable) will be called.

Specified by:

reindex in interface ReindexManager

waitForIndexJobsToBeProcessed

protected boolean waitForIndexJobsToBeProcessed()

getProcessEngineConfiguration

public org.flowable.engine.ProcessEngineConfiguration getProcessEngineConfiguration()

setProcessEngineConfiguration

public void setProcessEngineConfiguration(org.flowable.engine.ProcessEngineConfiguration processEngineConfiguration)