Package com.flowable.indexing.job.impl

Class BulkRequest

java.lang.Object

com.flowable.indexing.job.impl.BulkRequest

public class BulkRequest
extends Object

This is a custom class to do bulk requests to ES. Before, we used the org.elasticsearch.action.bulk.BulkRequest class from the high level client. However, this had limitations: the actual requests going to ES can't be retrieved later as everything is package-protected and final. We do need the original requests to schedule a new job for those that have failed. The alternative would be rebuilding the requests, but this is more expensive resource-wise, but definitely maintenance-wise: it would mean the logic would need to be implemented twice instead of in one place (which is of course more error-prone: with this implementation we simply take the original bulk requests and store them in the job without any additional processing. See the BulkIndexRequestExecutorImpl class for that implementation).

Field Summary

Fields

Modifier and Type	Field	Description
protected List<BulkRequestItem>	bulkRequestItems

Constructor Summary

Constructors

Constructor	Description
BulkRequest()

Method Summary

Modifier and Type	Method	Description
void	addBulkRequestItem(BulkRequestItem bulkRequestItem)
List<BulkRequestItem>	getBulkRequestItems()
void	setBulkRequestItems(List<BulkRequestItem> bulkRequestItems)

Methods inherited from class java.lang.Object

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

Field Details

bulkRequestItems

protected List<BulkRequestItem> bulkRequestItems

Constructor Details

BulkRequest

public BulkRequest()

Method Details

addBulkRequestItem

public void addBulkRequestItem(BulkRequestItem bulkRequestItem)

getBulkRequestItems

public List<BulkRequestItem> getBulkRequestItems()

setBulkRequestItems

public void setBulkRequestItems(List<BulkRequestItem> bulkRequestItems)