org.xbib.elasticsearch.action.websocket.bulk

Class BulkHandler.Builder

java.lang.Object

org.xbib.elasticsearch.action.websocket.bulk.BulkHandler.Builder

Enclosing class:

BulkHandler

public static class BulkHandler.Builder
extends Object

A builder used to create a build an instance of a bulk processor.

Constructor Summary

Constructors

Constructor and Description
BulkHandler.Builder(org.elasticsearch.client.Client client, BulkHandler.Listener listener) Creates a builder of bulk processor with the client to use and the listener that will be used to be notified on the completion of bulk requests.

Method Summary

Methods

Modifier and Type	Method and Description
BulkHandler	build() Builds a new bulk processor.
BulkHandler.Builder	setBulkActions(int bulkActions) Sets when to flush a new bulk request based on the number of actions currently added.
BulkHandler.Builder	setConcurrentRequests(int concurrentRequests) Sets the number of concurrent requests allowed to be executed.
BulkHandler.Builder	setFlushInterval(org.elasticsearch.common.unit.TimeValue flushInterval) Sets a flush interval flushing *any* bulk actions pending if the interval passes.

Methods inherited from class java.lang.Object

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

Constructor Detail

BulkHandler.Builder

public BulkHandler.Builder(org.elasticsearch.client.Client client,
                   BulkHandler.Listener listener)

Creates a builder of bulk processor with the client to use and the listener that will be used to be notified on the completion of bulk requests.

Method Detail

setConcurrentRequests

public BulkHandler.Builder setConcurrentRequests(int concurrentRequests)

Sets the number of concurrent requests allowed to be executed. A value of 0 means that only a single request will be allowed to be executed. A value of 1 means 1 concurrent request is allowed to be executed while accumulating new bulk requests. Defaults to 1.

setBulkActions

public BulkHandler.Builder setBulkActions(int bulkActions)

Sets when to flush a new bulk request based on the number of actions currently added. Defaults to 1000. Can be set to -1 to disable it.

setFlushInterval

public BulkHandler.Builder setFlushInterval(org.elasticsearch.common.unit.TimeValue flushInterval)

Sets a flush interval flushing *any* bulk actions pending if the interval passes. Defaults to not set.

Note, setBulkActions(int) can be set to -1 with the flush interval set allowing for complete async processing of bulk actions.

build

public BulkHandler build()

Builds a new bulk processor.