com.arakelian.elastic.bulk.event

Class LoggingIndexerListener

java.lang.Object

com.arakelian.elastic.bulk.event.LoggingIndexerListener

All Implemented Interfaces:

IndexerListener

public final class LoggingIndexerListener
extends java.lang.Object
implements IndexerListener

Field Summary

Fields

Modifier and Type	Field and Description
static LoggingIndexerListener	SINGLETON

Method Summary

Modifier and Type	Method and Description
void	closed(BulkIndexerStats stats) Finished
void	onFailure(BulkOperation op, BulkResponse.BulkOperationResponse response) Invoked when a BulkOperation fails individually.
void	onFailure(BulkOperation op, BulkResponse result) Invoked when a BulkOperation fails because the entire request to the Elastic Bulk API failed, always returning an HTTP status code outside the 2xx range.
void	onFailure(BulkOperation op, java.lang.Throwable t) Invoked when a BulkOperation fails because the entire request failed, usually due to an IOException.
void	onSuccess(BulkOperation op) Invoked when a BulkOperation is successful.

Methods inherited from class java.lang.Object

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

Field Detail

SINGLETON

public static final LoggingIndexerListener SINGLETON

Method Detail

closed

public void closed(BulkIndexerStats stats)

Description copied from interface: IndexerListener

Finished

Specified by:

closed in interface IndexerListener

Parameters:

stats - indexer stats

onFailure

public void onFailure(BulkOperation op,
                      BulkResponse.BulkOperationResponse response)

Description copied from interface: IndexerListener

Invoked when a BulkOperation fails individually. These operations always have a status code outside the 2xx range, and they are generally not retryable because they have status codes below the 5xx range, which are reserved for server-side issues.

Specified by:

onFailure in interface IndexerListener

Parameters:

op - bulk operation

response - bulk operation response

onFailure

public void onFailure(BulkOperation op,
                      BulkResponse result)

Description copied from interface: IndexerListener

Invoked when a BulkOperation fails because the entire request to the Elastic Bulk API failed, always returning an HTTP status code outside the 2xx range. Note: The bulk API request would been retried according to configured BulkIndexerConfig.getRetryer() policy.

Specified by:

onFailure in interface IndexerListener

Parameters:

op - bulk operation that failed

result - the response from the Elastic Bulk API, always with status code outside the 2xx range.

onFailure

public void onFailure(BulkOperation op,
                      java.lang.Throwable t)

Description copied from interface: IndexerListener

Invoked when a BulkOperation fails because the entire request failed, usually due to an IOException. It's possible that the Elastic Bulk API never received the request. Note: The bulk API request would been retried according to configured BulkIndexerConfig.getRetryer() policy.

Specified by:

onFailure in interface IndexerListener

Parameters:

op - bulk operation that failed

t - the exception that caused failure, usually an IOException

onSuccess

public void onSuccess(BulkOperation op)

Description copied from interface: IndexerListener

Invoked when a BulkOperation is successful. These operations usually have a status code in the 2xx range, but there are exceptions, such as 404 status code for delete operations which are benign and merely reported that the requested record was not found.

Specified by:

onSuccess in interface IndexerListener

Parameters:

op - bulk operation