com.flowable.indexing.job.impl

Class BulkIndexRequestExecutorImpl

java.lang.Object

com.flowable.indexing.job.impl.BulkIndexRequestExecutorImpl

All Implemented Interfaces:

BulkIndexRequestExecutor

public class BulkIndexRequestExecutorImpl
extends Object
implements BulkIndexRequestExecutor

Field Summary

Fields

Modifier and Type	Field and Description
protected ElasticsearchCompatibility	elasticsearchCompatibility
protected com.fasterxml.jackson.databind.ObjectMapper	objectMapper

Constructor Summary

Constructors

Constructor and Description
BulkIndexRequestExecutorImpl(com.fasterxml.jackson.databind.ObjectMapper objectMapper, ElasticsearchCompatibility elasticsearchCompatibility)

Method Summary

Modifier and Type	Method and Description
protected void	addHistoricData(AsyncIndexingHistorySession asyncIndexingHistorySession, String type, com.fasterxml.jackson.databind.node.ObjectNode data, String tenantId)
protected void	addHistoricData(org.flowable.job.service.impl.persistence.entity.HistoryJobEntity originalHistoryJobEntity, AsyncIndexingHistorySession asyncIndexingHistorySession, com.fasterxml.jackson.databind.node.ObjectNode objectNode)
void	execute(org.flowable.common.engine.impl.interceptor.CommandContext commandContext, org.flowable.job.service.impl.persistence.entity.HistoryJobEntity historyJob)
protected com.fasterxml.jackson.databind.JsonNode	getJobData(org.flowable.job.service.impl.persistence.entity.HistoryJobEntity job)
protected void	handleBulkResponse(org.flowable.common.engine.impl.interceptor.CommandContext commandContext, BulkIndexingSession bulkIndexingSession, org.flowable.job.service.impl.persistence.entity.HistoryJobEntity historyJob, BulkRequest bulkRequest, org.elasticsearch.action.bulk.BulkResponse bulkResponse)
protected void	rescheduleFailedHistoryJob(org.flowable.common.engine.impl.interceptor.CommandContext commandContext, org.flowable.job.service.impl.persistence.entity.HistoryJobEntity historyJobEntity)
protected void	scheduleNewHistoryJobForFailedRequests(org.flowable.common.engine.impl.interceptor.CommandContext commandContext, BulkIndexingSession bulkIndexingSession, org.flowable.job.service.impl.persistence.entity.HistoryJobEntity originalHistoryJobEntity, List<BulkRequestItem> failedRequests)

Methods inherited from class java.lang.Object

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

Field Detail

objectMapper

protected com.fasterxml.jackson.databind.ObjectMapper objectMapper

elasticsearchCompatibility

protected ElasticsearchCompatibility elasticsearchCompatibility

Constructor Detail

BulkIndexRequestExecutorImpl

public BulkIndexRequestExecutorImpl(com.fasterxml.jackson.databind.ObjectMapper objectMapper,
                                    ElasticsearchCompatibility elasticsearchCompatibility)

Method Detail

execute

public void execute(org.flowable.common.engine.impl.interceptor.CommandContext commandContext,
                    org.flowable.job.service.impl.persistence.entity.HistoryJobEntity historyJob)

Specified by:

execute in interface BulkIndexRequestExecutor

handleBulkResponse

protected void handleBulkResponse(org.flowable.common.engine.impl.interceptor.CommandContext commandContext,
                                  BulkIndexingSession bulkIndexingSession,
                                  org.flowable.job.service.impl.persistence.entity.HistoryJobEntity historyJob,
                                  BulkRequest bulkRequest,
                                  org.elasticsearch.action.bulk.BulkResponse bulkResponse)
                           throws IOException

Throws:

IOException

rescheduleFailedHistoryJob

protected void rescheduleFailedHistoryJob(org.flowable.common.engine.impl.interceptor.CommandContext commandContext,
                                          org.flowable.job.service.impl.persistence.entity.HistoryJobEntity historyJobEntity)
                                   throws IOException

Throws:

IOException

scheduleNewHistoryJobForFailedRequests

protected void scheduleNewHistoryJobForFailedRequests(org.flowable.common.engine.impl.interceptor.CommandContext commandContext,
                                                      BulkIndexingSession bulkIndexingSession,
                                                      org.flowable.job.service.impl.persistence.entity.HistoryJobEntity originalHistoryJobEntity,
                                                      List<BulkRequestItem> failedRequests)
                                               throws IOException

Throws:

IOException

getJobData

protected com.fasterxml.jackson.databind.JsonNode getJobData(org.flowable.job.service.impl.persistence.entity.HistoryJobEntity job)
                                                      throws IOException

Throws:

IOException

addHistoricData

protected void addHistoricData(org.flowable.job.service.impl.persistence.entity.HistoryJobEntity originalHistoryJobEntity,
                               AsyncIndexingHistorySession asyncIndexingHistorySession,
                               com.fasterxml.jackson.databind.node.ObjectNode objectNode)

addHistoricData

protected void addHistoricData(AsyncIndexingHistorySession asyncIndexingHistorySession,
                               String type,
                               com.fasterxml.jackson.databind.node.ObjectNode data,
                               String tenantId)