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(HistoryJobEntity originalHistoryJobEntity, AsyncIndexingHistorySession asyncIndexingHistorySession, com.fasterxml.jackson.databind.node.ObjectNode objectNode, CommandContext commandContext)
protected void	addHistoricData(HistoryJobEntity originalHistoryJobEntity, AsyncIndexingHistorySession asyncIndexingHistorySession, String type, com.fasterxml.jackson.databind.node.ObjectNode data, String tenantId, CommandContext commandContext)
void	execute(CommandContext commandContext, HistoryJobEntity historyJob)
protected com.fasterxml.jackson.databind.JsonNode	getJobData(HistoryJobEntity job)
protected JobServiceConfiguration	getJobServiceConfiguration(String scopeType, CommandContext commandContext)
protected void	handleBulkResponse(CommandContext commandContext, BulkIndexingSession bulkIndexingSession, HistoryJobEntity historyJob, BulkRequest bulkRequest, org.elasticsearch.action.bulk.BulkResponse bulkResponse)
protected void	scheduleNewHistoryJobForFailedRequests(CommandContext commandContext, BulkIndexingSession bulkIndexingSession, 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(CommandContext commandContext,
                    HistoryJobEntity historyJob)

Specified by:

execute in interface BulkIndexRequestExecutor

handleBulkResponse

protected void handleBulkResponse(CommandContext commandContext,
                                  BulkIndexingSession bulkIndexingSession,
                                  HistoryJobEntity historyJob,
                                  BulkRequest bulkRequest,
                                  org.elasticsearch.action.bulk.BulkResponse bulkResponse)
                           throws IOException

Throws:

IOException

scheduleNewHistoryJobForFailedRequests

protected void scheduleNewHistoryJobForFailedRequests(CommandContext commandContext,
                                                      BulkIndexingSession bulkIndexingSession,
                                                      HistoryJobEntity originalHistoryJobEntity,
                                                      List<BulkRequestItem> failedRequests)
                                               throws IOException

Throws:

IOException

getJobData

protected com.fasterxml.jackson.databind.JsonNode getJobData(HistoryJobEntity job)
                                                      throws IOException

Throws:

IOException

addHistoricData

protected void addHistoricData(HistoryJobEntity originalHistoryJobEntity,
                               AsyncIndexingHistorySession asyncIndexingHistorySession,
                               com.fasterxml.jackson.databind.node.ObjectNode objectNode,
                               CommandContext commandContext)

addHistoricData

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

getJobServiceConfiguration

protected JobServiceConfiguration getJobServiceConfiguration(String scopeType,
                                                             CommandContext commandContext)