Package com.flowable.indexing.job

Class IndexDataAsyncHistoryJobHandler

java.lang.Object

com.flowable.indexing.job.AbstractAsyncHistoryJobHandler

com.flowable.indexing.job.IndexDataAsyncHistoryJobHandler

All Implemented Interfaces:

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(HistoryJobEntity historyJob, String configuration, CommandContext commandContext, JobServiceConfiguration jobServiceConfiguration)
protected void	executeHistoryTransformers(CommandContext commandContext, HistoryJobEntity job, com.fasterxml.jackson.databind.node.ObjectNode historicalJsonData, List<HistoryJsonTransformer> transformers)
protected List<HistoryJobEntity>	generateHistoryJobs(JobServiceConfiguration jobServiceConfiguration, List<com.fasterxml.jackson.databind.node.ObjectNode> historyObjectNodes)
HistoryJsonTransformer	getDefaultHistoryJsonTransformer()
Map<String,List<HistoryJsonTransformer>>	getHistoryJsonTransformers()
protected void	handleNoMatchingHistoryTransformer(CommandContext commandContext, HistoryJobEntity job, com.fasterxml.jackson.databind.node.ObjectNode historicalData, String type)
protected void	processHistoryJson(CommandContext commandContext, 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(HistoryJobEntity historyJob,
 String configuration,
 CommandContext commandContext,
 JobServiceConfiguration jobServiceConfiguration)

Specified by:

execute in interface HistoryJobHandler

Overrides:

execute in class AbstractAsyncHistoryJobHandler

processHistoryJson

protected void processHistoryJson(CommandContext commandContext,
 HistoryJobEntity job,
 com.fasterxml.jackson.databind.JsonNode historyNode)

Specified by:

processHistoryJson in class AbstractAsyncHistoryJobHandler

executeHistoryTransformers

protected void executeHistoryTransformers(CommandContext commandContext,
 HistoryJobEntity job,
 com.fasterxml.jackson.databind.node.ObjectNode historicalJsonData,
 List<HistoryJsonTransformer> transformers)

handleNoMatchingHistoryTransformer

protected void handleNoMatchingHistoryTransformer(CommandContext commandContext,
 HistoryJobEntity job,
 com.fasterxml.jackson.databind.node.ObjectNode historicalData,
 String type)

generateHistoryJobs

protected List<HistoryJobEntity> generateHistoryJobs(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)