Package com.flowable.indexing.job

Class IndexZippedDataAsyncHistoryJobHandler

java.lang.Object

com.flowable.indexing.job.AbstractAsyncHistoryJobHandler

com.flowable.indexing.job.IndexDataAsyncHistoryJobHandler

com.flowable.indexing.job.IndexZippedDataAsyncHistoryJobHandler

All Implemented Interfaces:

org.flowable.job.service.HistoryJobHandler

public class IndexZippedDataAsyncHistoryJobHandler
extends IndexDataAsyncHistoryJobHandler

Field Summary

Fields

Modifier and Type	Field	Description
static final String	JOB_TYPE

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

bulkIndexRequestExecutor, defaultHistoryJsonTransformer, historyJsonTransformers, jobProducer

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

isAsyncHistoryJsonGroupingEnabled, jobType, logger

Constructor Summary

Constructors

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

Method Summary

Modifier and Type	Method	Description
protected byte[]	decompress(byte[] compressed)
protected byte[]	getJobBytes(org.flowable.job.service.impl.persistence.entity.HistoryJobEntity job)

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

addHistoryJsonTransformer, execute, executeHistoryTransformers, generateHistoryJobs, getDefaultHistoryJsonTransformer, getHistoryJsonTransformers, handleNoMatchingHistoryTransformer, processHistoryJson, setDefaultHistoryJsonTransformer, setHistoryJsonTransformers

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

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

Constructor Details

IndexZippedDataAsyncHistoryJobHandler

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

Method Details

getJobBytes

protected byte[] getJobBytes(org.flowable.job.service.impl.persistence.entity.HistoryJobEntity job)

Overrides:

getJobBytes in class AbstractAsyncHistoryJobHandler

decompress

protected byte[] decompress(byte[] compressed)