com.flowable.indexing.job.history.async

Interface BulkIndexRequestInterceptor

public interface BulkIndexRequestInterceptor

An interceptor that will be called before and/or after the execution of a BulkRequest in the BulkIndexingSession.

Method Summary

Modifier and Type	Method and Description
void	afterRequestExecution(BulkRequest bulkRequest, org.elasticsearch.action.bulk.BulkResponse bulkResponse)
void	beforeRequestAddToBulkIndexingSession(String index, IndexedDataObject indexedDataObject, com.fasterxml.jackson.databind.node.ObjectNode originalData)
void	beforeRequestExecution(BulkRequest bulkRequest)

Method Detail

beforeRequestAddToBulkIndexingSession

void beforeRequestAddToBulkIndexingSession(String index,
                                           IndexedDataObject indexedDataObject,
                                           com.fasterxml.jackson.databind.node.ObjectNode originalData)

beforeRequestExecution

void beforeRequestExecution(BulkRequest bulkRequest)

afterRequestExecution

void afterRequestExecution(BulkRequest bulkRequest,
                           org.elasticsearch.action.bulk.BulkResponse bulkResponse)