com.flowable.indexing.job

Class IndexZippedDataAsyncHistoryJobHandler

java.lang.Object

org.flowable.job.service.impl.history.async.AbstractAsyncHistoryJobHandler

org.flowable.job.service.impl.history.async.AsyncHistoryJobHandler

org.flowable.job.service.impl.history.async.AsyncHistoryJobZippedHandler

com.flowable.indexing.job.IndexZippedDataAsyncHistoryJobHandler

All Implemented Interfaces:

HistoryJobHandler

public class IndexZippedDataAsyncHistoryJobHandler
extends AsyncHistoryJobZippedHandler

Field Summary

Fields

Modifier and Type	Field and Description
protected BulkIndexRequestExecutor	bulkIndexRequestExecutor
static String	JOB_TYPE

Fields inherited from class org.flowable.job.service.impl.history.async.AsyncHistoryJobHandler

defaultHistoryJsonTransformer, historyJsonTransformers

Fields inherited from class org.flowable.job.service.impl.history.async.AbstractAsyncHistoryJobHandler

isAsyncHistoryJsonGroupingEnabled, jobType, logger

Constructor Summary

Constructors

Constructor and Description
IndexZippedDataAsyncHistoryJobHandler(List<HistoryJsonTransformer> historyJsonTransformers, BulkIndexRequestExecutor bulkIndexRequestExecutor)

Method Summary

Modifier and Type	Method and Description
void	execute(HistoryJobEntity job, String configuration, CommandContext commandContext, JobServiceConfiguration jobServiceConfiguration)
String	getType()
protected void	handleNoMatchingHistoryTransformer(CommandContext commandContext, HistoryJobEntity job, com.fasterxml.jackson.databind.node.ObjectNode historicalData, String type)

Methods inherited from class org.flowable.job.service.impl.history.async.AsyncHistoryJobZippedHandler

decompress, getJobBytes

Methods inherited from class org.flowable.job.service.impl.history.async.AsyncHistoryJobHandler

addHistoryJsonTransformer, executeHistoryTransformers, getDefaultHistoryJsonTransformer, getHistoryJsonTransformers, processHistoryJson, setDefaultHistoryJsonTransformer, setHistoryJsonTransformers

Methods inherited from class org.flowable.job.service.impl.history.async.AbstractAsyncHistoryJobHandler

isAsyncHistoryJsonGroupingEnabled, setAsyncHistoryJsonGroupingEnabled

Methods inherited from class java.lang.Object

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

Field Detail

JOB_TYPE

public static final String JOB_TYPE

See Also:

Constant Field Values

bulkIndexRequestExecutor

protected BulkIndexRequestExecutor bulkIndexRequestExecutor

Constructor Detail

IndexZippedDataAsyncHistoryJobHandler

public IndexZippedDataAsyncHistoryJobHandler(List<HistoryJsonTransformer> historyJsonTransformers,
                                             BulkIndexRequestExecutor bulkIndexRequestExecutor)

Method Detail

execute

public void execute(HistoryJobEntity job,
                    String configuration,
                    CommandContext commandContext,
                    JobServiceConfiguration jobServiceConfiguration)

Specified by:

execute in interface HistoryJobHandler

Overrides:

execute in class AbstractAsyncHistoryJobHandler

getType

public String getType()

Specified by:

getType in interface HistoryJobHandler

Overrides:

getType in class AbstractAsyncHistoryJobHandler

handleNoMatchingHistoryTransformer

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

Overrides:

handleNoMatchingHistoryTransformer in class AsyncHistoryJobHandler