Package 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	Description
protected int	defaultNrOfRetries
protected ElasticsearchCompatibility	elasticsearchCompatibility
protected com.fasterxml.jackson.databind.ObjectMapper	objectMapper

Constructor Summary

Constructors

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

Method Summary

Modifier and Type	Method	Description
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 JobServiceConfiguration	getJobServiceConfiguration(String scopeType, CommandContext commandContext)
protected void	handleBulkResponse(CommandContext commandContext, BulkIndexingSession bulkIndexingSession, HistoryJobEntity historyJob, BulkRequest bulkRequest, ElasticsearchBulkResponse bulkResponse)
protected void	scheduleNewHistoryJobForRequestsInError(CommandContext commandContext, BulkIndexingSession bulkIndexingSession, HistoryJobEntity originalHistoryJobEntity, List<BulkRequestItem> failedRequests, List<BulkRequestItem> conflictingRequests)
protected boolean	shouldScheduleNewHistoryJobForRequestsInError(HistoryJobEntity historyJobEntity, List<BulkRequestItem> failedRequests, List<BulkRequestItem> conflictingRequests)

Methods inherited from class java.lang.Object

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

Field Details

objectMapper

protected com.fasterxml.jackson.databind.ObjectMapper objectMapper

elasticsearchCompatibility

protected ElasticsearchCompatibility elasticsearchCompatibility

defaultNrOfRetries

protected int defaultNrOfRetries

Constructor Details

BulkIndexRequestExecutorImpl

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

Method Details

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,
 ElasticsearchBulkResponse bulkResponse)

shouldScheduleNewHistoryJobForRequestsInError

protected boolean shouldScheduleNewHistoryJobForRequestsInError(HistoryJobEntity historyJobEntity,
 List<BulkRequestItem> failedRequests,
 List<BulkRequestItem> conflictingRequests)

scheduleNewHistoryJobForRequestsInError

protected void scheduleNewHistoryJobForRequestsInError(CommandContext commandContext,
 BulkIndexingSession bulkIndexingSession,
 HistoryJobEntity originalHistoryJobEntity,
 List<BulkRequestItem> failedRequests,
 List<BulkRequestItem> conflictingRequests)

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)