Class 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).
    • Constructor Detail

      • BulkRequest

        public BulkRequest()