org.opennms.plugins.elasticsearch.rest.bulk

Class BulkRequest<T>

java.lang.Object

org.opennms.plugins.elasticsearch.rest.bulk.BulkRequest<T>

public class BulkRequest<T>
extends Object

Field Summary

Fields

Modifier and Type	Field and Description
static long[]	SLEEP_TIME

Constructor Summary

Constructors

Constructor and Description
BulkRequest(io.searchbox.client.JestClient client, List<T> documents, java.util.function.Function<List<T>,BulkWrapper> documentToBulkTransformer, int retryCount)

Method Summary

Modifier and Type	Method and Description
BulkResultWrapper	execute()
static long	getSleepTime(int retry)

Methods inherited from class java.lang.Object

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

Field Detail

SLEEP_TIME

public static long[] SLEEP_TIME

Constructor Detail

BulkRequest

public BulkRequest(io.searchbox.client.JestClient client,
                   List<T> documents,
                   java.util.function.Function<List<T>,BulkWrapper> documentToBulkTransformer,
                   int retryCount)

Method Detail

execute

public BulkResultWrapper execute()
                          throws IOException

Throws:

IOException

getSleepTime

public static long getSleepTime(int retry)