Class ReindexManagerImpl

java.lang.Object

com.flowable.indexing.ReindexManagerImpl

All Implemented Interfaces:

ReindexManager

public class ReindexManagerImpl
extends Object
implements ReindexManager

Starts a resumable reindex batch within a single DB transaction. The index-page parts are deliberately not created here; the status timer creates them only once the dual-write propagation window has elapsed, so no entity is read for the backfill until every pod is guaranteed to be dual-writing to the new index.

Field Summary

Fields

Modifier and Type	Field	Description
protected final ElasticsearchClient	elasticsearchClient
protected final org.flowable.engine.impl.cfg.ProcessEngineConfigurationImpl	engineConfiguration
protected final IndexManager	indexManager
protected final ReindexingProperties	reindexingProperties

Constructor Summary

Constructors

Constructor	Description
ReindexManagerImpl(org.flowable.engine.ProcessEngineConfiguration processEngineConfiguration, ElasticsearchClient elasticsearchClient, IndexManager indexManager, ReindexingProperties reindexingProperties)

Method Summary

Modifier and Type	Method	Description
protected ReindexBatchDocument	buildBatchDocument(Map<String, ReindexEntityPageHandler> handlers, int pageSize)
void	reindex(String alias, Map<String, ReindexEntityPageHandler> handlerMap)
protected void	rejectIfActiveBatchExists(String alias)
protected String	serializeJson(tools.jackson.databind.ObjectMapper objectMapper, Object obj)

Methods inherited from class Object

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

Field Details

engineConfiguration

protected final org.flowable.engine.impl.cfg.ProcessEngineConfigurationImpl engineConfiguration

elasticsearchClient

protected final ElasticsearchClient elasticsearchClient

indexManager

protected final IndexManager indexManager

reindexingProperties

protected final ReindexingProperties reindexingProperties

Constructor Details

ReindexManagerImpl

public ReindexManagerImpl(org.flowable.engine.ProcessEngineConfiguration processEngineConfiguration,
 ElasticsearchClient elasticsearchClient,
 IndexManager indexManager,
 ReindexingProperties reindexingProperties)

Method Details

reindex

public void reindex(String alias,
 Map<String, ReindexEntityPageHandler> handlerMap)

Specified by:

reindex in interface ReindexManager

rejectIfActiveBatchExists

protected void rejectIfActiveBatchExists(String alias)

buildBatchDocument

protected ReindexBatchDocument buildBatchDocument(Map<String, ReindexEntityPageHandler> handlers,
 int pageSize)

serializeJson

protected String serializeJson(tools.jackson.databind.ObjectMapper objectMapper,
 Object obj)