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:
  • 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