public class ElasticErrorBulkRequest extends Object
If something wrong happens, tuples are failed.
Constructor and Description |
---|
ElasticErrorBulkRequest(ElasticsearchOutput output,
org.elasticsearch.client.RestHighLevelClient client,
org.elasticsearch.action.bulk.BulkRequest bulkRequest,
List<ElasticDocument> documents) |
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) |
ElasticErrorBulkRequest |
setFailTupleWhenErrorNotIndexed(boolean b) |
public ElasticErrorBulkRequest(ElasticsearchOutput output, org.elasticsearch.client.RestHighLevelClient client, org.elasticsearch.action.bulk.BulkRequest bulkRequest, List<ElasticDocument> documents)
public void execute(com.codahale.metrics.Timer.Context timer, com.codahale.metrics.Counter batchNumber, org.thales.punch.libraries.utils.api.Every every)
public ElasticErrorBulkRequest setFailTupleWhenErrorNotIndexed(boolean b)
Copyright © 2023. All rights reserved.