Package 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	Description
StormElasticSearchClient(EsConfig esConfig)

Method Summary

Modifier and Type	Method	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 Details

StormElasticSearchClient

public StormElasticSearchClient(EsConfig esConfig)

Method Details

construct

public org.elasticsearch.client.RestClient construct()

Creates a new RestClient using given EsConfig.

Returns:

RestClient for Elasticsearch connection