org.apache.storm.elasticsearch.common

Class StormElasticSearchClient

java.lang.Object

org.apache.storm.elasticsearch.common.StormElasticSearchClient

All Implemented Interfaces:

Serializable

public final class StormElasticSearchClient
extends Object
implements Serializable

Client for connecting Elasticsearch.

See Also:

Serialized Form

Constructor Summary

Constructors

Constructor and Description
StormElasticSearchClient(EsConfig esConfig)

Method Summary

Modifier and Type	Method and Description
org.elasticsearch.client.RestClient	construct() Creates a new RestClient using given EsConfig.

Methods inherited from class java.lang.Object

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

Constructor Detail

StormElasticSearchClient

public StormElasticSearchClient(EsConfig esConfig)

Method Detail

construct

public org.elasticsearch.client.RestClient construct()

Creates a new RestClient using given EsConfig.

Returns:

RestClient for Elasticsearch connection