org.thales.punch.libraries.storm.bolt.elasticsearch

Class ElasticBulkRequest

java.lang.Object

org.thales.punch.libraries.storm.bolt.elasticsearch.ElasticBulkRequest

public class ElasticBulkRequest
extends Object

This class only takes care of executing a single bulk request for the regular input document.

It performs the necessary actions depending on its success or failure.

In case of error, it will request th elastic output node to re-trigger a second re-indexation into an error index. That second indexation is taken care of by a ElasticErrorBulkRequest instance.

Author:

dimi

Constructor Summary

Constructors

Constructor and Description
ElasticBulkRequest(ElasticsearchOutput output, org.elasticsearch.client.RestHighLevelClient client, org.elasticsearch.action.bulk.BulkRequest bulkRequest, ElasticDocument[] documents, int bulkEffectiveSize)

Method Summary

Modifier and Type	Method and Description
void	execute(com.codahale.metrics.Timer.Context timer, com.codahale.metrics.Counter batchNumber, org.thales.punch.libraries.utils.api.Every every)
ElasticBulkRequest	setBulkFailureHandler(FailureHandler handler)
ElasticBulkRequest	setFailedDocumentReindexation(boolean b)
ElasticBulkRequest	setFailedDocumentReindexationForMappingExceptionsOnly(boolean b)
ElasticBulkRequest	setFailTupleWhenErrorNotIndexed(boolean b)
ElasticBulkRequest	setUnavailabilityFailureHandler(FailureHandler handler)

Methods inherited from class java.lang.Object

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

Constructor Detail

ElasticBulkRequest

public ElasticBulkRequest(ElasticsearchOutput output,
                          org.elasticsearch.client.RestHighLevelClient client,
                          org.elasticsearch.action.bulk.BulkRequest bulkRequest,
                          ElasticDocument[] documents,
                          int bulkEffectiveSize)

Method Detail

execute

public void execute(com.codahale.metrics.Timer.Context timer,
                    com.codahale.metrics.Counter batchNumber,
                    org.thales.punch.libraries.utils.api.Every every)

setFailedDocumentReindexation

public ElasticBulkRequest setFailedDocumentReindexation(boolean b)

setFailedDocumentReindexationForMappingExceptionsOnly

public ElasticBulkRequest setFailedDocumentReindexationForMappingExceptionsOnly(boolean b)

setFailTupleWhenErrorNotIndexed

public ElasticBulkRequest setFailTupleWhenErrorNotIndexed(boolean b)

setBulkFailureHandler

public ElasticBulkRequest setBulkFailureHandler(FailureHandler handler)

setUnavailabilityFailureHandler

public ElasticBulkRequest setUnavailabilityFailureHandler(FailureHandler handler)