Class BulkProcessor

All Implemented Interfaces:
Closeable, AutoCloseable

public class BulkProcessor extends Object implements Closeable
A bulk processor is a thread safe bulk processing class, allowing to easily set when to "flush" a new bulk request (either based on number of actions, based on the size, or time), and to easily control the number of concurrent bulk requests allowed to be executed in parallel.

In order to create a new bulk processor, use the BulkProcessor.Builder.