Package | Description |
---|---|
org.apache.storm.elasticsearch.bolt | |
org.apache.storm.elasticsearch.common | |
org.apache.storm.elasticsearch.trident |
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 © 2019 The Apache Software Foundation. All Rights Reserved.