org.xbib.elasticsearch.plugin.jdbc.client.node

Class BulkNodeClient

java.lang.Object

org.xbib.elasticsearch.plugin.jdbc.client.node.BulkNodeClient

All Implemented Interfaces:

Ingest

public class BulkNodeClient
extends Object
implements Ingest

Node client support with bulk processing

Constructor Summary

Constructors

Constructor and Description
BulkNodeClient()

Method Summary

Methods

Modifier and Type	Method and Description
void	addSetting(String key, Boolean value) Create a key/value in the settings
void	addSetting(String key, Integer value) Create a key/value in the settings
void	addSetting(String key, String value) Create a key/value in the settings
BulkNodeClient	bulkDelete(org.elasticsearch.action.delete.DeleteRequest deleteRequest) Bulked delete request.
BulkNodeClient	bulkIndex(org.elasticsearch.action.index.IndexRequest indexRequest) Bulked index request.
org.elasticsearch.client.Client	client()
BulkNodeClient	delete(String index, String type, String id) Delete document
BulkNodeClient	deleteIndex(String index) Delete index
BulkNodeClient	deleteMapping(String index, String type)
BulkNodeClient	flush(String index) Flush the index
BulkNodeClient	flushIngest() Flush ingest, move all pending documents to the bulk indexer
BulkNodeClient	flushIngestInterval(org.elasticsearch.common.unit.TimeValue flushInterval) Set the flush interval for automatic flushing outstanding ingest requests
List<String>	getConnectedNodes()
Map<String,String>	getMappings()
Metric	getMetric()
org.elasticsearch.common.settings.Settings	getSettings()
org.elasticsearch.common.settings.ImmutableSettings.Builder	getSettingsBuilder()
Throwable	getThrowable() Return last throwable if exists.
boolean	hasThrowable()
BulkNodeClient	index(String index, String type, String id, String source) Index document
boolean	isShutdown()
void	mapping(String type, InputStream in)
void	mapping(String type, String mapping)
BulkNodeClient	maxActionsPerBulkRequest(int maxActionsPerBulkRequest) Set the maximum number of actions per bulk request
BulkNodeClient	maxConcurrentBulkRequests(int maxConcurrentBulkRequests) Set the maximum concurent bulk requests
BulkNodeClient	maxRequestWait(org.elasticsearch.common.unit.TimeValue timeValue) Set request timeout.
BulkNodeClient	maxVolumePerBulkRequest(org.elasticsearch.common.unit.ByteSizeValue maxVolume) Set the maximum volume for bulk request before flush
BulkNodeClient	newClient(org.elasticsearch.client.Client client)
BulkNodeClient	newClient(Map<String,String> client)
BulkNodeClient	newClient(org.elasticsearch.common.settings.Settings settings)
BulkNodeClient	newIndex(String index) Create a new index
BulkNodeClient	newIndex(String index, org.elasticsearch.common.settings.Settings settings, Map<String,String> mappings)
BulkNodeClient	newIndex(String index, String type, InputStream settings, InputStream mappings)
BulkNodeClient	putMapping(String index)
BulkNodeClient	refresh(String index) Refresh the index.
BulkNodeClient	replica(int replica) The number of replica for index creation
void	resume()
void	setSettings(org.elasticsearch.common.settings.Settings settings)
void	setting(InputStream in) Create settings
BulkNodeClient	shards(int shards) The number of shards for index creation
void	shutdown() Shutdown the ingesting
BulkNodeClient	startBulk(String index) Start bulk mode
BulkNodeClient	stopBulk(String index) Stops bulk mode.
void	suspend()
int	updateReplicaLevel(String index, int level) Add replica level.
BulkNodeClient	waitForCluster(org.elasticsearch.action.admin.cluster.health.ClusterHealthStatus status, org.elasticsearch.common.unit.TimeValue timeout) Wait for cluster being healthy.
int	waitForRecovery(String index) Wait for index recovery (after replica change)
BulkNodeClient	waitForResponses(org.elasticsearch.common.unit.TimeValue maxWaitTime) Wait for all outstanding responses

Methods inherited from class java.lang.Object

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

Constructor Detail

BulkNodeClient

public BulkNodeClient()

Method Detail

shards

public BulkNodeClient shards(int shards)

Description copied from interface: Ingest

The number of shards for index creation

Specified by:

shards in interface Ingest

Parameters:

shards - the number of shards

Returns:

this

replica

public BulkNodeClient replica(int replica)

Description copied from interface: Ingest

The number of replica for index creation

Specified by:

replica in interface Ingest

Parameters:

replica - the number of replica

Returns:

this

maxActionsPerBulkRequest

public BulkNodeClient maxActionsPerBulkRequest(int maxActionsPerBulkRequest)

Description copied from interface: Ingest

Set the maximum number of actions per bulk request

Specified by:

maxActionsPerBulkRequest in interface Ingest

Parameters:

maxActionsPerBulkRequest - maximum number of bulk actions

Returns:

this ingest

maxConcurrentBulkRequests

public BulkNodeClient maxConcurrentBulkRequests(int maxConcurrentBulkRequests)

Description copied from interface: Ingest

Set the maximum concurent bulk requests

Specified by:

maxConcurrentBulkRequests in interface Ingest

Parameters:

maxConcurrentBulkRequests - maximum number of concurrent ingest requests

Returns:

this Ingest

maxVolumePerBulkRequest

public BulkNodeClient maxVolumePerBulkRequest(org.elasticsearch.common.unit.ByteSizeValue maxVolume)

Description copied from interface: Ingest

Set the maximum volume for bulk request before flush

Specified by:

maxVolumePerBulkRequest in interface Ingest

Parameters:

maxVolume - maximum volume

Returns:

this ingest

maxRequestWait

public BulkNodeClient maxRequestWait(org.elasticsearch.common.unit.TimeValue timeValue)

Description copied from interface: Ingest

Set request timeout. Default is 60s.

Specified by:

maxRequestWait in interface Ingest

Parameters:

timeValue - timeout

Returns:

this ingest

flushIngestInterval

public BulkNodeClient flushIngestInterval(org.elasticsearch.common.unit.TimeValue flushInterval)

Description copied from interface: Ingest

Set the flush interval for automatic flushing outstanding ingest requests

Specified by:

flushIngestInterval in interface Ingest

Parameters:

flushInterval - the flush interval, default is 30 seconds

Returns:

this ingest

newClient

public BulkNodeClient newClient(org.elasticsearch.common.settings.Settings settings)

Specified by:

newClient in interface Ingest

newClient

public BulkNodeClient newClient(Map<String,String> client)

Specified by:

newClient in interface Ingest

getConnectedNodes

public List<String> getConnectedNodes()

Specified by:

getConnectedNodes in interface Ingest

newClient

public BulkNodeClient newClient(org.elasticsearch.client.Client client)

Specified by:

newClient in interface Ingest

client

public org.elasticsearch.client.Client client()

Specified by:

client in interface Ingest

getMetric

public Metric getMetric()

Specified by:

getMetric in interface Ingest

putMapping

public BulkNodeClient putMapping(String index)

Specified by:

putMapping in interface Ingest

deleteMapping

public BulkNodeClient deleteMapping(String index,
                           String type)

Specified by:

deleteMapping in interface Ingest

index

public BulkNodeClient index(String index,
                   String type,
                   String id,
                   String source)

Description copied from interface: Ingest

Index document

Specified by:

index in interface Ingest

Parameters:

index - the index

type - the type

id - the id

source - the source

Returns:

this

bulkIndex

public BulkNodeClient bulkIndex(org.elasticsearch.action.index.IndexRequest indexRequest)

Description copied from interface: Ingest

Bulked index request. Each request will be added to a queue for bulking requests. Submitting request will be done when bulk limits are exceeded.

Specified by:

bulkIndex in interface Ingest

Parameters:

indexRequest - the index request to add

Returns:

this ingest

delete

public BulkNodeClient delete(String index,
                    String type,
                    String id)

Description copied from interface: Ingest

Delete document

Specified by:

delete in interface Ingest

Parameters:

index - the index

type - the type

id - the id

Returns:

this

bulkDelete

public BulkNodeClient bulkDelete(org.elasticsearch.action.delete.DeleteRequest deleteRequest)

Description copied from interface: Ingest

Bulked delete request. Each request will be added to a queue for bulking requests. Submitting request will be done when bulk limits are exceeded.

Specified by:

bulkDelete in interface Ingest

Parameters:

deleteRequest - the delete request to add

Returns:

this ingest

flushIngest

public BulkNodeClient flushIngest()

Description copied from interface: Ingest

Flush ingest, move all pending documents to the bulk indexer

Specified by:

flushIngest in interface Ingest

Returns:

this

waitForResponses

public BulkNodeClient waitForResponses(org.elasticsearch.common.unit.TimeValue maxWaitTime)
                                throws InterruptedException

Description copied from interface: Ingest

Wait for all outstanding responses

Specified by:

waitForResponses in interface Ingest

Parameters:

maxWaitTime - maximum wait time

Returns:

this ingest

Throws:

InterruptedException

startBulk

public BulkNodeClient startBulk(String index)
                         throws IOException

Description copied from interface: Ingest

Start bulk mode

Specified by:

startBulk in interface Ingest

Returns:

this ingest

Throws:

IOException

stopBulk

public BulkNodeClient stopBulk(String index)
                        throws IOException

Description copied from interface: Ingest

Stops bulk mode. Enables refresh.

Specified by:

stopBulk in interface Ingest

Returns:

this Ingest

Throws:

IOException

flush

public BulkNodeClient flush(String index)

Description copied from interface: Ingest

Flush the index

Specified by:

flush in interface Ingest

refresh

public BulkNodeClient refresh(String index)

Description copied from interface: Ingest

Refresh the index.

Specified by:

refresh in interface Ingest

Returns:

this ingest

updateReplicaLevel

public int updateReplicaLevel(String index,
                     int level)
                       throws IOException

Description copied from interface: Ingest

Add replica level.

Specified by:

updateReplicaLevel in interface Ingest

level - the replica level

Returns:

number of shards after updating replica level

Throws:

IOException

waitForCluster

public BulkNodeClient waitForCluster(org.elasticsearch.action.admin.cluster.health.ClusterHealthStatus status,
                            org.elasticsearch.common.unit.TimeValue timeout)
                              throws IOException

Description copied from interface: Ingest

Wait for cluster being healthy.

Specified by:

waitForCluster in interface Ingest

Throws:

IOException

waitForRecovery

public int waitForRecovery(String index)
                    throws IOException

Description copied from interface: Ingest

Wait for index recovery (after replica change)

Specified by:

waitForRecovery in interface Ingest

Returns:

number of shards found

Throws:

IOException

shutdown

public void shutdown()

Description copied from interface: Ingest

Shutdown the ingesting

Specified by:

shutdown in interface Ingest

isShutdown

public boolean isShutdown()

Specified by:

isShutdown in interface Ingest

suspend

public void suspend()

Specified by:

suspend in interface Ingest

resume

public void resume()

Specified by:

resume in interface Ingest

newIndex

public BulkNodeClient newIndex(String index)
                        throws IOException

Description copied from interface: Ingest

Create a new index

Specified by:

newIndex in interface Ingest

Returns:

this ingest

Throws:

IOException

newIndex

public BulkNodeClient newIndex(String index,
                      String type,
                      InputStream settings,
                      InputStream mappings)
                        throws IOException

Specified by:

newIndex in interface Ingest

Throws:

IOException

newIndex

public BulkNodeClient newIndex(String index,
                      org.elasticsearch.common.settings.Settings settings,
                      Map<String,String> mappings)
                        throws IOException

Specified by:

newIndex in interface Ingest

Throws:

IOException

deleteIndex

public BulkNodeClient deleteIndex(String index)

Description copied from interface: Ingest

Delete index

Specified by:

deleteIndex in interface Ingest

Returns:

this ingest

hasThrowable

public boolean hasThrowable()

Specified by:

hasThrowable in interface Ingest

getThrowable

public Throwable getThrowable()

Description copied from interface: Ingest

Return last throwable if exists.

Specified by:

getThrowable in interface Ingest

Returns:

last throwable

setSettings

public void setSettings(org.elasticsearch.common.settings.Settings settings)

Specified by:

setSettings in interface Ingest

getSettings

public org.elasticsearch.common.settings.Settings getSettings()

Specified by:

getSettings in interface Ingest

getSettingsBuilder

public org.elasticsearch.common.settings.ImmutableSettings.Builder getSettingsBuilder()

Specified by:

getSettingsBuilder in interface Ingest

setting

public void setting(InputStream in)
             throws IOException

Description copied from interface: Ingest

Create settings

Specified by:

setting in interface Ingest

Parameters:

in - the input stream with settings

Throws:

IOException

addSetting

public void addSetting(String key,
              String value)

Description copied from interface: Ingest

Create a key/value in the settings

Specified by:

addSetting in interface Ingest

Parameters:

key - the key

value - the value

addSetting

public void addSetting(String key,
              Boolean value)

Description copied from interface: Ingest

Create a key/value in the settings

Specified by:

addSetting in interface Ingest

Parameters:

key - the key

value - the value

addSetting

public void addSetting(String key,
              Integer value)

Description copied from interface: Ingest

Create a key/value in the settings

Specified by:

addSetting in interface Ingest

Parameters:

key - the key

value - the value

mapping

public void mapping(String type,
           InputStream in)
             throws IOException

Specified by:

mapping in interface Ingest

Throws:

IOException

mapping

public void mapping(String type,
           String mapping)
             throws IOException

Specified by:

mapping in interface Ingest

Throws:

IOException

getMappings

public Map<String,String> getMappings()

Specified by:

getMappings in interface Ingest