Package | Description |
---|---|
org.apache.storm.elasticsearch.bolt |
ElasticSearch examples classes.
|
org.apache.storm.elasticsearch.common |
Shared code for example classes.
|
org.apache.storm.elasticsearch.trident |
ElasticSearch Trident example classes.
|
Constructor and Description |
---|
AbstractEsBolt(EsConfig esConfig) |
EsIndexBolt(EsConfig esConfig)
EsIndexBolt constructor.
|
EsIndexBolt(EsConfig esConfig,
EsTupleMapper tupleMapper)
EsIndexBolt constructor.
|
EsLookupBolt(EsConfig esConfig)
EsLookupBolt constructor.
|
EsLookupBolt(EsConfig esConfig,
EsTupleMapper tupleMapper,
EsLookupResultOutput output)
EsLookupBolt constructor.
|
EsPercolateBolt(EsConfig esConfig)
EsPercolateBolt constructor.
|
EsPercolateBolt(EsConfig esConfig,
EsTupleMapper tupleMapper)
EsPercolateBolt constructor.
|
Modifier and Type | Method and Description |
---|---|
EsConfig |
EsConfig.withDefaultHeaders(org.apache.http.Header[] defaultHeaders) |
EsConfig |
EsConfig.withFailureListener(org.elasticsearch.client.RestClient.FailureListener failureListener) |
EsConfig |
EsConfig.withHttpClientConfigCallback(org.elasticsearch.client.RestClientBuilder.HttpClientConfigCallback httpClientConfigCallback) |
EsConfig |
EsConfig.withMaxRetryTimeoutMillis(Integer maxRetryTimeoutMillis) |
EsConfig |
EsConfig.withPathPrefix(String pathPrefix) |
EsConfig |
EsConfig.withRequestConfigCallback(org.elasticsearch.client.RestClientBuilder.RequestConfigCallback requestConfigCallback) |
Constructor and Description |
---|
StormElasticSearchClient(EsConfig esConfig) |
Constructor and Description |
---|
EsStateFactory(EsConfig esConfig,
EsTupleMapper tupleMapper)
EsStateFactory constructor.
|
Copyright © 2020 The Apache Software Foundation. All rights reserved.