Package 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 Description
    void afterBulk​(long executionId, BulkRequest request, java.lang.Throwable failure)
    Callback after a failed execution of bulk request.
    void afterBulk​(long executionId, BulkRequest request, BulkResponse response)
    Callback after a successful execution of bulk request.
    void beforeBulk​(long executionId, BulkRequest request)
    Callback before the bulk is executed.

  • Method Details

    • 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.