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 java.lang.Object
implements BulkIndexRequestExecutor

  • Field Summary

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

  • Constructor Summary

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

  • Method Summary

    Modifier and Type Method Description
    protected void addHistoricData​(AsyncIndexingHistorySession asyncIndexingHistorySession, java.lang.String type, com.fasterxml.jackson.databind.node.ObjectNode data, java.lang.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, java.util.List<BulkRequestItem> failedRequests)  

    Methods inherited from class java.lang.Object

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

  • Field Details

  • Constructor Details

  • Method Details

    • 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 java.io.IOException
      Throws:
      java.io.IOException

    • rescheduleFailedHistoryJob

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

    • scheduleNewHistoryJobForFailedRequests

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

    • getJobData

      protected com.fasterxml.jackson.databind.JsonNode getJobData​(org.flowable.job.service.impl.persistence.entity.HistoryJobEntity job) throws java.io.IOException
      Throws:
      java.io.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, java.lang.String type, com.fasterxml.jackson.databind.node.ObjectNode data, java.lang.String tenantId)