public class IndexZippedDataAsyncHistoryJobHandler
extends org.flowable.job.service.impl.history.async.AsyncHistoryJobZippedHandler
Modifier and Type | Field and Description |
---|---|
protected BulkIndexRequestExecutor |
bulkIndexRequestExecutor |
static String |
JOB_TYPE |
Constructor and Description |
---|
IndexZippedDataAsyncHistoryJobHandler(List<org.flowable.job.service.impl.history.async.transformer.HistoryJsonTransformer> historyJsonTransformers,
BulkIndexRequestExecutor bulkIndexRequestExecutor) |
Modifier and Type | Method and Description |
---|---|
void |
execute(org.flowable.job.service.impl.persistence.entity.HistoryJobEntity job,
String configuration,
org.flowable.common.engine.impl.interceptor.CommandContext commandContext) |
String |
getType() |
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) |
decompress, getJobBytes
addHistoryJsonTransformer, executeHistoryTransformers, getDefaultHistoryJsonTransformer, getHistoryJsonTransformers, processHistoryJson, setDefaultHistoryJsonTransformer, setHistoryJsonTransformers
public static final String JOB_TYPE
protected BulkIndexRequestExecutor bulkIndexRequestExecutor
public IndexZippedDataAsyncHistoryJobHandler(List<org.flowable.job.service.impl.history.async.transformer.HistoryJsonTransformer> historyJsonTransformers, BulkIndexRequestExecutor bulkIndexRequestExecutor)
public void execute(org.flowable.job.service.impl.persistence.entity.HistoryJobEntity job, String configuration, org.flowable.common.engine.impl.interceptor.CommandContext commandContext)
execute
in interface org.flowable.job.service.HistoryJobHandler
execute
in class org.flowable.job.service.impl.history.async.AbstractAsyncHistoryJobHandler
public String getType()
getType
in interface org.flowable.job.service.HistoryJobHandler
getType
in class org.flowable.job.service.impl.history.async.AbstractAsyncHistoryJobHandler
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)
handleNoMatchingHistoryTransformer
in class org.flowable.job.service.impl.history.async.AsyncHistoryJobHandler
Copyright © 2019. All rights reserved.