org.elasticsearch.action.bulk

Interface BulkProcessor.Listener

Enclosing class:

BulkProcessor

public static interface BulkProcessor.Listener

A listener for the execution.

Method Summary

Modifier and Type	Method and Description
void	afterBulk(long executionId, BulkRequest request, BulkResponse response) Callback after a successful execution of bulk request.
void	afterBulk(long executionId, BulkRequest request, java.lang.Throwable failure) Callback after a failed execution of bulk request.
void	beforeBulk(long executionId, BulkRequest request) Callback before the bulk is executed.

Method Detail

beforeBulk

void beforeBulk(long executionId,
                BulkRequest request)

Callback before the bulk is executed.

afterBulk

void afterBulk(long executionId,
               BulkRequest request,
               BulkResponse response)

Callback after a successful execution of bulk request.

afterBulk

void afterBulk(long executionId,
               BulkRequest request,
               java.lang.Throwable failure)

Callback after a failed execution of bulk request.

Note that in case an instance of InterruptedException is passed, which means that request processing has been cancelled externally, the thread's interruption status has been restored prior to calling this method.