Package com.flowable.indexing.job

Class IndexDataAsyncHistoryJobHandler

java.lang.Object

com.flowable.indexing.job.AbstractAsyncHistoryJobHandler

com.flowable.indexing.job.IndexDataAsyncHistoryJobHandler

All Implemented Interfaces:

org.flowable.job.service.HistoryJobHandler

Direct Known Subclasses:

IndexZippedDataAsyncHistoryJobHandler

public class IndexDataAsyncHistoryJobHandler
extends AbstractAsyncHistoryJobHandler

Field Summary

Fields

Modifier and Type	Field	Description
protected BulkIndexRequestExecutor	bulkIndexRequestExecutor
protected HistoryJsonTransformer	defaultHistoryJsonTransformer
protected Map<String,List<HistoryJsonTransformer>>	historyJsonTransformers
static final String	JOB_TYPE
protected final IndexingHistoryJobProducer	jobProducer

Fields inherited from class com.flowable.indexing.job.AbstractAsyncHistoryJobHandler

isAsyncHistoryJsonGroupingEnabled, jobType, logger

Constructor Summary

Constructors

Constructor	Description
IndexDataAsyncHistoryJobHandler(IndexingHistoryJobProducer jobProducer, List<HistoryJsonTransformer> historyJsonTransformers, BulkIndexRequestExecutor bulkIndexRequestExecutor)
IndexDataAsyncHistoryJobHandler(String jobType, IndexingHistoryJobProducer jobProducer, List<HistoryJsonTransformer> historyJsonTransformers, BulkIndexRequestExecutor bulkIndexRequestExecutor)

Method Summary

Modifier and Type	Method	Description
void	addHistoryJsonTransformer(HistoryJsonTransformer historyJsonTransformer)
void	execute(org.flowable.job.service.impl.persistence.entity.HistoryJobEntity historyJob, String configuration, org.flowable.common.engine.impl.interceptor.CommandContext commandContext, org.flowable.job.service.JobServiceConfiguration jobServiceConfiguration)
protected void	executeHistoryTransformers(org.flowable.common.engine.impl.interceptor.CommandContext commandContext, org.flowable.job.service.impl.persistence.entity.HistoryJobEntity job, com.fasterxml.jackson.databind.node.ObjectNode historicalJsonData, List<HistoryJsonTransformer> transformers)
protected List<org.flowable.job.service.impl.persistence.entity.HistoryJobEntity>	generateHistoryJobs(org.flowable.job.service.JobServiceConfiguration jobServiceConfiguration, List<com.fasterxml.jackson.databind.node.ObjectNode> historyObjectNodes)
HistoryJsonTransformer	getDefaultHistoryJsonTransformer()
Map<String,List<HistoryJsonTransformer>>	getHistoryJsonTransformers()
protected void	handleNoMatchingHistoryTransformer(org.flowable.common.engine.impl.interceptor.CommandContext commandContext, org.flowable.job.service.impl.persistence.entity.HistoryJobEntity job, com.fasterxml.jackson.databind.node.ObjectNode historicalData, String type)
protected void	processHistoryJson(org.flowable.common.engine.impl.interceptor.CommandContext commandContext, org.flowable.job.service.impl.persistence.entity.HistoryJobEntity job, com.fasterxml.jackson.databind.JsonNode historyNode)
void	setDefaultHistoryJsonTransformer(HistoryJsonTransformer defaultHistoryJsonTransformer)
void	setHistoryJsonTransformers(Map<String,List<HistoryJsonTransformer>> historyJsonTransformers)

Methods inherited from class com.flowable.indexing.job.AbstractAsyncHistoryJobHandler

getJobBytes, getType, isAsyncHistoryJsonGroupingEnabled, setAsyncHistoryJsonGroupingEnabled

Methods inherited from class java.lang.Object

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

Field Details

JOB_TYPE

public static final String JOB_TYPE

See Also:

• Constant Field Values

jobProducer

protected final IndexingHistoryJobProducer jobProducer

bulkIndexRequestExecutor

protected BulkIndexRequestExecutor bulkIndexRequestExecutor

historyJsonTransformers

protected Map<String,List<HistoryJsonTransformer>> historyJsonTransformers

defaultHistoryJsonTransformer

protected HistoryJsonTransformer defaultHistoryJsonTransformer

Constructor Details

IndexDataAsyncHistoryJobHandler

public IndexDataAsyncHistoryJobHandler(IndexingHistoryJobProducer jobProducer,
 List<HistoryJsonTransformer> historyJsonTransformers,
 BulkIndexRequestExecutor bulkIndexRequestExecutor)

IndexDataAsyncHistoryJobHandler

public IndexDataAsyncHistoryJobHandler(String jobType,
 IndexingHistoryJobProducer jobProducer,
 List<HistoryJsonTransformer> historyJsonTransformers,
 BulkIndexRequestExecutor bulkIndexRequestExecutor)

Method Details

addHistoryJsonTransformer

public void addHistoryJsonTransformer(HistoryJsonTransformer historyJsonTransformer)

execute

public void execute(org.flowable.job.service.impl.persistence.entity.HistoryJobEntity historyJob,
 String configuration,
 org.flowable.common.engine.impl.interceptor.CommandContext commandContext,
 org.flowable.job.service.JobServiceConfiguration jobServiceConfiguration)

Specified by:

execute in interface org.flowable.job.service.HistoryJobHandler

Overrides:

execute in class AbstractAsyncHistoryJobHandler

processHistoryJson

protected void processHistoryJson(org.flowable.common.engine.impl.interceptor.CommandContext commandContext,
 org.flowable.job.service.impl.persistence.entity.HistoryJobEntity job,
 com.fasterxml.jackson.databind.JsonNode historyNode)

Specified by:

processHistoryJson in class AbstractAsyncHistoryJobHandler

executeHistoryTransformers

protected void executeHistoryTransformers(org.flowable.common.engine.impl.interceptor.CommandContext commandContext,
 org.flowable.job.service.impl.persistence.entity.HistoryJobEntity job,
 com.fasterxml.jackson.databind.node.ObjectNode historicalJsonData,
 List<HistoryJsonTransformer> transformers)

handleNoMatchingHistoryTransformer

protected void handleNoMatchingHistoryTransformer(org.flowable.common.engine.impl.interceptor.CommandContext commandContext,
 org.flowable.job.service.impl.persistence.entity.HistoryJobEntity job,
 com.fasterxml.jackson.databind.node.ObjectNode historicalData,
 String type)

generateHistoryJobs

protected List<org.flowable.job.service.impl.persistence.entity.HistoryJobEntity> generateHistoryJobs(org.flowable.job.service.JobServiceConfiguration jobServiceConfiguration,
 List<com.fasterxml.jackson.databind.node.ObjectNode> historyObjectNodes)

Specified by:

generateHistoryJobs in class AbstractAsyncHistoryJobHandler

getHistoryJsonTransformers

public Map<String,List<HistoryJsonTransformer>> getHistoryJsonTransformers()

setHistoryJsonTransformers

public void setHistoryJsonTransformers(Map<String,List<HistoryJsonTransformer>> historyJsonTransformers)

getDefaultHistoryJsonTransformer

public HistoryJsonTransformer getDefaultHistoryJsonTransformer()

setDefaultHistoryJsonTransformer

public void setDefaultHistoryJsonTransformer(HistoryJsonTransformer defaultHistoryJsonTransformer)