com.flowable.indexing.job.transformer

Class GenericIndexingTransformer

java.lang.Object

com.flowable.indexing.job.transformer.GenericIndexingTransformer

All Implemented Interfaces:

org.flowable.job.service.impl.history.async.transformer.HistoryJsonTransformer

public class GenericIndexingTransformer
extends Object
implements org.flowable.job.service.impl.history.async.transformer.HistoryJsonTransformer

A generic indexing transformer that just gets the data and sends it to ES as is.

Field Summary

Fields

Modifier and Type	Field and Description
protected LowLevelIndexingService	indexingService
protected com.fasterxml.jackson.databind.ObjectMapper	objectMapper

Fields inherited from interface org.flowable.job.service.impl.history.async.transformer.HistoryJsonTransformer

FIELD_NAME_DATA, FIELD_NAME_TYPE

Constructor Summary

Constructors

Constructor and Description
GenericIndexingTransformer(LowLevelIndexingService indexingService, com.fasterxml.jackson.databind.ObjectMapper objectMapper)

Method Summary

Modifier and Type	Method and Description
List<String>	getTypes()
boolean	isApplicable(com.fasterxml.jackson.databind.node.ObjectNode historicalData, org.flowable.common.engine.impl.interceptor.CommandContext commandContext)
void	transformJson(org.flowable.job.service.impl.persistence.entity.HistoryJobEntity job, com.fasterxml.jackson.databind.node.ObjectNode historicalData, org.flowable.common.engine.impl.interceptor.CommandContext commandContext)

Methods inherited from class java.lang.Object

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

Field Detail

indexingService

protected final LowLevelIndexingService indexingService

objectMapper

protected final com.fasterxml.jackson.databind.ObjectMapper objectMapper

Constructor Detail

GenericIndexingTransformer

public GenericIndexingTransformer(LowLevelIndexingService indexingService,
                                  com.fasterxml.jackson.databind.ObjectMapper objectMapper)

Method Detail

getTypes

public List<String> getTypes()

Specified by:

getTypes in interface org.flowable.job.service.impl.history.async.transformer.HistoryJsonTransformer

isApplicable

public boolean isApplicable(com.fasterxml.jackson.databind.node.ObjectNode historicalData,
                            org.flowable.common.engine.impl.interceptor.CommandContext commandContext)

Specified by:

isApplicable in interface org.flowable.job.service.impl.history.async.transformer.HistoryJsonTransformer

transformJson

public void transformJson(org.flowable.job.service.impl.persistence.entity.HistoryJobEntity job,
                          com.fasterxml.jackson.databind.node.ObjectNode historicalData,
                          org.flowable.common.engine.impl.interceptor.CommandContext commandContext)

Specified by:

transformJson in interface org.flowable.job.service.impl.history.async.transformer.HistoryJsonTransformer