org.xbib.elasticsearch.action.websocket.bulk

Class BulkHandler

java.lang.Object

org.elasticsearch.common.component.AbstractComponent

org.xbib.elasticsearch.websocket.BaseInteractiveHandler

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

All Implemented Interfaces:

InteractiveHandler

Direct Known Subclasses:

BulkDeleteAction, BulkFlushAction, BulkIndexAction

public class BulkHandler
extends BaseInteractiveHandler

The bulk handler is derived from the BulkProcessor, but offers explicit flushing and can receive requests from multiple threads into a global action queue. It supports websocket bulk actions and can write back response to an interactive channel. The bulk volume is not controlled. The default concurrency is 32, the number of actions in a bulk is 100.

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static class	BulkHandler.Builder A builder used to create a build an instance of a bulk processor.
static interface	BulkHandler.Listener A listener for the execution.

Field Summary

Fields inherited from class org.xbib.elasticsearch.websocket.BaseInteractiveHandler

client

Fields inherited from class org.elasticsearch.common.component.AbstractComponent

componentSettings, logger, settings

Constructor Summary

Constructors

Constructor and Description
BulkHandler(org.elasticsearch.common.settings.Settings settings, org.elasticsearch.client.Client client)

Method Summary

Methods

Modifier and Type	Method and Description
BulkHandler	add(org.elasticsearch.action.ActionRequest request)
BulkHandler	add(org.elasticsearch.action.ActionRequest request, InteractiveChannel channel)
BulkHandler	add(org.elasticsearch.action.delete.DeleteRequest request) Adds an DeleteRequest to the list of actions to execute.
BulkHandler	add(org.elasticsearch.action.delete.DeleteRequest request, InteractiveChannel channel) Adds an DeleteRequest to the list of actions to execute.
BulkHandler	add(org.elasticsearch.action.index.IndexRequest request) Adds an IndexRequest to the list of actions to execute.
BulkHandler	add(org.elasticsearch.action.index.IndexRequest request, InteractiveChannel channel) Adds an IndexRequest to the list of actions to execute.
static BulkHandler.Builder	builder(org.elasticsearch.client.Client client, BulkHandler.Listener listener)
void	close() Closes the processor.
void	flush() Flushes open bulk actions
void	flush(InteractiveChannel channel) Flushes open bulk actions
BulkHandler.Listener	getListener()
void	handleRequest(InteractiveRequest request, InteractiveChannel channel)

Methods inherited from class org.elasticsearch.common.component.AbstractComponent

nodeName

Methods inherited from class java.lang.Object

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

Constructor Detail

BulkHandler

public BulkHandler(org.elasticsearch.common.settings.Settings settings,
           org.elasticsearch.client.Client client)

Method Detail

handleRequest

public void handleRequest(InteractiveRequest request,
                 InteractiveChannel channel)

builder

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

getListener

public BulkHandler.Listener getListener()

flush

public void flush()

Flushes open bulk actions

flush

public void flush(InteractiveChannel channel)

Flushes open bulk actions

close

public void close()

Closes the processor. If flushing by time is enabled, then its shutdown. Any remaining bulk actions are flushed.

add

public BulkHandler add(org.elasticsearch.action.index.IndexRequest request)

Adds an IndexRequest to the list of actions to execute. Follows the same behavior of IndexRequest (for example, if no id is provided, one will be generated, or usage of the create flag).

add

public BulkHandler add(org.elasticsearch.action.delete.DeleteRequest request)

Adds an DeleteRequest to the list of actions to execute.

add

public BulkHandler add(org.elasticsearch.action.ActionRequest request)

add

public BulkHandler add(org.elasticsearch.action.index.IndexRequest request,
              InteractiveChannel channel)

Adds an IndexRequest to the list of actions to execute. Follows the same behavior of IndexRequest (for example, if no id is provided, one will be generated, or usage of the create flag).

add

public BulkHandler add(org.elasticsearch.action.delete.DeleteRequest request,
              InteractiveChannel channel)

Adds an DeleteRequest to the list of actions to execute.

add

public BulkHandler add(org.elasticsearch.action.ActionRequest request,
              InteractiveChannel channel)