Serialized Form (storm-elasticsearch-examples 2.2.0 API)

Package org.apache.storm.elasticsearch.bolt
- Class org.apache.storm.elasticsearch.bolt.AbstractEsBolt extends BaseTickTupleAwareRichBolt implements Serializable
  - Serialized Fields
    - collector
```
OutputCollector collector
```
    - esConfig
```
EsConfig esConfig
```
- Class org.apache.storm.elasticsearch.bolt.EsIndexBolt extends AbstractEsBolt implements Serializable
  - Serialized Fields
    - tupleMapper
```
EsTupleMapper tupleMapper
```
- Class org.apache.storm.elasticsearch.bolt.EsIndexTopology.UserDataSpout extends BaseRichSpout implements Serializable
  
  serialVersionUID:
  
  1L
  - Serialized Fields
    - pending
```
ConcurrentHashMap<K,V> pending
```
      The pending values.
    - collector
```
SpoutOutputCollector collector
```
      The collector passed in EsIndexTopology.UserDataSpout.open(java.util.Map, org.apache.storm.task.TopologyContext, org.apache.storm.spout.SpoutOutputCollector).
    - sources
```
String[] sources
```
    - index
```
int index
```
    - count
```
int count
```
    - total
```
long total
```
    - indexName
```
String indexName
```
    - typeName
```
String typeName
```
- Class org.apache.storm.elasticsearch.bolt.EsLookupBolt extends AbstractEsBolt implements Serializable
  - Serialized Fields
    - tupleMapper
```
EsTupleMapper tupleMapper
```
    - output
```
EsLookupResultOutput output
```
- Class org.apache.storm.elasticsearch.bolt.EsPercolateBolt extends AbstractEsBolt implements Serializable
  - Serialized Fields
    - tupleMapper
```
EsTupleMapper tupleMapper
```
Package org.apache.storm.elasticsearch.common
- Class org.apache.storm.elasticsearch.common.DefaultEsTupleMapper extends Object implements Serializable
- Class org.apache.storm.elasticsearch.common.EsConfig extends Object implements Serializable
  - Serialized Fields
    - httpHosts
```
org.apache.http.HttpHost[] httpHosts
```
    - maxRetryTimeoutMillis
```
Integer maxRetryTimeoutMillis
```
    - defaultHeaders
```
org.apache.http.Header[] defaultHeaders
```
    - failureListener
```
org.elasticsearch.client.RestClient.FailureListener failureListener
```
    - httpClientConfigCallback
```
org.elasticsearch.client.RestClientBuilder.HttpClientConfigCallback httpClientConfigCallback
```
    - requestConfigCallback
```
org.elasticsearch.client.RestClientBuilder.RequestConfigCallback requestConfigCallback
```
    - pathPrefix
```
String pathPrefix
```
- Class org.apache.storm.elasticsearch.common.StormElasticSearchClient extends Object implements Serializable
  - Serialized Fields
    - esConfig
```
EsConfig esConfig
```
Package org.apache.storm.elasticsearch.trident
- Class org.apache.storm.elasticsearch.trident.EsStateFactory extends Object implements Serializable
  - Serialized Fields
    - esConfig
```
EsConfig esConfig
```
    - tupleMapper
```
EsTupleMapper tupleMapper
```
- Class org.apache.storm.elasticsearch.trident.EsUpdater extends BaseStateUpdater<org.apache.storm.elasticsearch.trident.EsState> implements Serializable
- Class org.apache.storm.elasticsearch.trident.TridentEsTopology.FixedBatchSpout extends Object implements Serializable
  
  serialVersionUID:
  
  1L
  - Serialized Fields
    - maxBatchSize
```
int maxBatchSize
```
    - batches
```
HashMap<K,V> batches
```
      The passed batches.
    - outputs
```
Values[] outputs
```
      The output values.
    - index
```
int index
```
      The current index.
    - cycle
```
boolean cycle
```
      A flag indicating whether cycling ought to be performed.

Serialized Form

Package org.apache.storm.elasticsearch.bolt

Class org.apache.storm.elasticsearch.bolt.AbstractEsBolt extends BaseTickTupleAwareRichBolt implements Serializable

Serialized Fields

collector

esConfig

Class org.apache.storm.elasticsearch.bolt.EsIndexBolt extends AbstractEsBolt implements Serializable

Serialized Fields

tupleMapper

Class org.apache.storm.elasticsearch.bolt.EsIndexTopology.UserDataSpout extends BaseRichSpout implements Serializable

Serialized Fields

pending

collector

sources

index

count

total

indexName

typeName

Class org.apache.storm.elasticsearch.bolt.EsLookupBolt extends AbstractEsBolt implements Serializable

Serialized Fields

tupleMapper

output

Class org.apache.storm.elasticsearch.bolt.EsPercolateBolt extends AbstractEsBolt implements Serializable

Serialized Fields

tupleMapper

Package org.apache.storm.elasticsearch.common

Class org.apache.storm.elasticsearch.common.DefaultEsTupleMapper extends Object implements Serializable

Class org.apache.storm.elasticsearch.common.EsConfig extends Object implements Serializable

Serialized Fields

httpHosts

maxRetryTimeoutMillis

defaultHeaders

failureListener

httpClientConfigCallback

requestConfigCallback

pathPrefix

Class org.apache.storm.elasticsearch.common.StormElasticSearchClient extends Object implements Serializable

Serialized Fields

esConfig

Package org.apache.storm.elasticsearch.trident

Class org.apache.storm.elasticsearch.trident.EsStateFactory extends Object implements Serializable

Serialized Fields

esConfig

tupleMapper

Class org.apache.storm.elasticsearch.trident.EsUpdater extends BaseStateUpdater<org.apache.storm.elasticsearch.trident.EsState> implements Serializable

Class org.apache.storm.elasticsearch.trident.TridentEsTopology.FixedBatchSpout extends Object implements Serializable

Serialized Fields

maxBatchSize

batches

outputs

index

cycle