public class IndexDataAsyncHistoryJobHandler extends AsyncHistoryJobHandler
Modifier and Type | Field and Description |
---|---|
protected BulkIndexRequestExecutor |
bulkIndexRequestExecutor |
static String |
JOB_TYPE |
defaultHistoryJsonTransformer, historyJsonTransformers
isAsyncHistoryJsonGroupingEnabled, jobType, logger
Constructor and Description |
---|
IndexDataAsyncHistoryJobHandler(List<HistoryJsonTransformer> historyJsonTransformers,
BulkIndexRequestExecutor bulkIndexRequestExecutor) |
Modifier and Type | Method and Description |
---|---|
void |
execute(HistoryJobEntity historyJob,
String configuration,
CommandContext commandContext,
JobServiceConfiguration jobServiceConfiguration) |
String |
getType() |
protected void |
handleNoMatchingHistoryTransformer(CommandContext commandContext,
HistoryJobEntity job,
com.fasterxml.jackson.databind.node.ObjectNode historicalData,
String type) |
addHistoryJsonTransformer, executeHistoryTransformers, getDefaultHistoryJsonTransformer, getHistoryJsonTransformers, processHistoryJson, setDefaultHistoryJsonTransformer, setHistoryJsonTransformers
getJobBytes, isAsyncHistoryJsonGroupingEnabled, setAsyncHistoryJsonGroupingEnabled
public static final String JOB_TYPE
protected BulkIndexRequestExecutor bulkIndexRequestExecutor
public IndexDataAsyncHistoryJobHandler(List<HistoryJsonTransformer> historyJsonTransformers, BulkIndexRequestExecutor bulkIndexRequestExecutor)
public void execute(HistoryJobEntity historyJob, String configuration, CommandContext commandContext, JobServiceConfiguration jobServiceConfiguration)
execute
in interface HistoryJobHandler
execute
in class AbstractAsyncHistoryJobHandler
public String getType()
getType
in interface HistoryJobHandler
getType
in class AbstractAsyncHistoryJobHandler
protected void handleNoMatchingHistoryTransformer(CommandContext commandContext, HistoryJobEntity job, com.fasterxml.jackson.databind.node.ObjectNode historicalData, String type)
handleNoMatchingHistoryTransformer
in class AsyncHistoryJobHandler