public class IndexDataAsyncHistoryJobHandler extends AsyncHistoryJobHandler
| Modifier and Type | Field and Description |
|---|---|
protected BulkIndexRequestExecutor |
bulkIndexRequestExecutor |
static String |
JOB_TYPE |
defaultHistoryJsonTransformer, historyJsonTransformersisAsyncHistoryJsonGroupingEnabled, 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, setHistoryJsonTransformersgetJobBytes, isAsyncHistoryJsonGroupingEnabled, setAsyncHistoryJsonGroupingEnabledpublic 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 HistoryJobHandlerexecute in class AbstractAsyncHistoryJobHandlerpublic String getType()
getType in interface HistoryJobHandlergetType in class AbstractAsyncHistoryJobHandlerprotected void handleNoMatchingHistoryTransformer(CommandContext commandContext, HistoryJobEntity job, com.fasterxml.jackson.databind.node.ObjectNode historicalData, String type)
handleNoMatchingHistoryTransformer in class AsyncHistoryJobHandler