public interface Listener {
void beforeBulk(long executionId, BulkRequest request);
void afterBulk(long executionId, BulkRequest request, BulkResponse response);
void afterBulk(long executionId, BulkRequest request, Throwable failure);
}
<BUG>public static BulkProcessor simpleBulkProcessor(ElasticsearchClient client, int bulkSize, TimeValue flushInterval) {
</BUG>
return builder(client, new Listener() {
@Override
public void beforeBulk(long executionId, BulkRequest request) {

public interface Listener {
void beforeBulk(long executionId, BulkRequest request);
void afterBulk(long executionId, BulkRequest request, BulkResponse response);
void afterBulk(long executionId, BulkRequest request, Throwable failure);
}
public static BulkProcessor simpleBulkProcessor(ElasticsearchClient client, int bulkSize, TimeValue flushInterval, String pipeline) {
return builder(client, new Listener() {
@Override
public void beforeBulk(long executionId, BulkRequest request) {
