org.apache.storm.elasticsearch.common

Class EsConfig

java.lang.Object

org.apache.storm.elasticsearch.common.EsConfig

All Implemented Interfaces:

Serializable

public class EsConfig
extends Object
implements Serializable

Configuration for Elasticsearch connection.

Since:

0.11

See Also:

Serialized Form

Constructor Summary

Constructors

Constructor and Description
EsConfig() EsConfig Constructor to be used in EsIndexBolt, EsPercolateBolt and EsStateFactory.
EsConfig(String... urls) EsConfig Constructor to be used in EsIndexBolt, EsPercolateBolt and EsStateFactory.

Method Summary

Modifier and Type	Method and Description
org.apache.http.Header[]	getDefaultHeaders()
org.elasticsearch.client.RestClient.FailureListener	getFailureListener()
org.elasticsearch.client.RestClientBuilder.HttpClientConfigCallback	getHttpClientConfigCallback()
org.apache.http.HttpHost[]	getHttpHosts()
Integer	getMaxRetryTimeoutMillis()
String	getPathPrefix()
org.elasticsearch.client.RestClientBuilder.RequestConfigCallback	getRequestConfigCallback()
EsConfig	withDefaultHeaders(org.apache.http.Header[] defaultHeaders)
EsConfig	withFailureListener(org.elasticsearch.client.RestClient.FailureListener failureListener)
EsConfig	withHttpClientConfigCallback(org.elasticsearch.client.RestClientBuilder.HttpClientConfigCallback httpClientConfigCallback)
EsConfig	withMaxRetryTimeoutMillis(Integer maxRetryTimeoutMillis)
EsConfig	withPathPrefix(String pathPrefix)
EsConfig	withRequestConfigCallback(org.elasticsearch.client.RestClientBuilder.RequestConfigCallback requestConfigCallback)

Methods inherited from class java.lang.Object

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

Constructor Detail

EsConfig

public EsConfig()

EsConfig Constructor to be used in EsIndexBolt, EsPercolateBolt and EsStateFactory. Connects to Elasticsearch at http://localhost:9200.

EsConfig

public EsConfig(String... urls)

EsConfig Constructor to be used in EsIndexBolt, EsPercolateBolt and EsStateFactory.

Parameters:

urls - Elasticsearch addresses in scheme://host:port pattern string array

Throws:

IllegalArgumentException - if urls are empty

NullPointerException - on any of the fields being null

Method Detail

withMaxRetryTimeoutMillis

public EsConfig withMaxRetryTimeoutMillis(Integer maxRetryTimeoutMillis)

withDefaultHeaders

public EsConfig withDefaultHeaders(org.apache.http.Header[] defaultHeaders)

withFailureListener

public EsConfig withFailureListener(org.elasticsearch.client.RestClient.FailureListener failureListener)

withHttpClientConfigCallback

public EsConfig withHttpClientConfigCallback(org.elasticsearch.client.RestClientBuilder.HttpClientConfigCallback httpClientConfigCallback)

withRequestConfigCallback

public EsConfig withRequestConfigCallback(org.elasticsearch.client.RestClientBuilder.RequestConfigCallback requestConfigCallback)

withPathPrefix

public EsConfig withPathPrefix(String pathPrefix)

getHttpHosts

public org.apache.http.HttpHost[] getHttpHosts()

getMaxRetryTimeoutMillis

public Integer getMaxRetryTimeoutMillis()

getDefaultHeaders

public org.apache.http.Header[] getDefaultHeaders()

getFailureListener

public org.elasticsearch.client.RestClient.FailureListener getFailureListener()

getHttpClientConfigCallback

public org.elasticsearch.client.RestClientBuilder.HttpClientConfigCallback getHttpClientConfigCallback()

getRequestConfigCallback

public org.elasticsearch.client.RestClientBuilder.RequestConfigCallback getRequestConfigCallback()

getPathPrefix

public String getPathPrefix()