Serialized Form (streams-persist-elasticsearch 0.5.2-SNAPSHOT API)

Package org.apache.streams.elasticsearch
- Class org.apache.streams.elasticsearch.ElasticsearchConfiguration extends Object implements Serializable
  - Serialized Fields
    - hosts
```
List<E> hosts
```
      Elasticsearch Hosts
    - port
```
Long port
```
      Elasticsearch Transport API port
    - clusterName
```
String clusterName
```
      Cluster Name
    - additionalProperties
```
Map<K,V> additionalProperties
```
- Class org.apache.streams.elasticsearch.ElasticsearchPersistDeleter extends ElasticsearchPersistWriter implements Serializable
- Class org.apache.streams.elasticsearch.ElasticsearchPersistReader extends Object implements Serializable
  - Serialized Fields
    - persistQueue
```
Queue<E> persistQueue
```
    - elasticsearchQuery
```
ElasticsearchQuery elasticsearchQuery
```
    - config
```
ElasticsearchReaderConfiguration config
```
    - threadPoolSize
```
int threadPoolSize
```
    - executor
```
ExecutorService executor
```
    - lock
```
ReadWriteLock lock
```
    - readerTask
```
Future<V> readerTask
```
- Class org.apache.streams.elasticsearch.ElasticsearchPersistUpdater extends ElasticsearchPersistWriter implements Serializable
- Class org.apache.streams.elasticsearch.ElasticsearchPersistWriter extends Object implements Serializable
  - Serialized Fields
    - affectedIndexes
```
List<E> affectedIndexes
```
    - manager
```
ElasticsearchClientManager manager
```
    - config
```
ElasticsearchWriterConfiguration config
```
    - bulkRequest
```
org.elasticsearch.action.bulk.BulkRequestBuilder bulkRequest
```
    - veryLargeBulk
```
boolean veryLargeBulk
```
    - flushThresholdsRecords
```
long flushThresholdsRecords
```
    - flushThresholdBytes
```
long flushThresholdBytes
```
    - flushThresholdTime
```
long flushThresholdTime
```
    - lastFlush
```
long lastFlush
```
    - timer
```
Timer timer
```
    - batchesSent
```
AtomicInteger batchesSent
```
    - batchesResponded
```
AtomicInteger batchesResponded
```
    - currentBatchItems
```
AtomicLong currentBatchItems
```
    - currentBatchBytes
```
AtomicLong currentBatchBytes
```
    - totalSent
```
AtomicLong totalSent
```
    - totalSeconds
```
AtomicLong totalSeconds
```
    - totalOk
```
AtomicLong totalOk
```
    - totalFailed
```
AtomicLong totalFailed
```
    - totalSizeInBytes
```
AtomicLong totalSizeInBytes
```
- Class org.apache.streams.elasticsearch.ElasticsearchQuery extends Object implements Serializable
  - Serialized Fields
    - elasticsearchClientManager
```
ElasticsearchClientManager elasticsearchClientManager
```
    - config
```
ElasticsearchReaderConfiguration config
```
    - indexes
```
List<E> indexes
```
    - types
```
List<E> types
```
    - limit
```
int limit
```
    - batchSize
```
int batchSize
```
    - scrollTimeout
```
String scrollTimeout
```
    - queryBuilder
```
org.elasticsearch.index.query.QueryBuilder queryBuilder
```
    - search
```
org.elasticsearch.action.search.SearchRequestBuilder search
```
    - scrollResp
```
org.elasticsearch.action.search.SearchResponse scrollResp
```
    - scrollPositionInScroll
```
int scrollPositionInScroll
```
    - next
```
org.elasticsearch.search.SearchHit next
```
    - totalHits
```
long totalHits
```
    - totalRead
```
long totalRead
```
    - mapper
```
StreamsJacksonMapper mapper
```
- Class org.apache.streams.elasticsearch.ElasticsearchReaderConfiguration extends ElasticsearchConfiguration implements Serializable
  - Serialized Fields
    - indexes
```
List<E> indexes
```
      Indexes to read from
    - types
```
List<E> types
```
      Types to read from
    - scrollTimeout
```
String scrollTimeout
```
      Scroll Timeout (JodaTime)
    - Search
```
Map<K,V> Search
```
      Search definition
    - additionalProperties
```
Map<K,V> additionalProperties
```
- Class org.apache.streams.elasticsearch.ElasticsearchWriterConfiguration extends ElasticsearchConfiguration implements Serializable
  - Serialized Fields
    - index
```
String index
```
      Index to write to
    - type
```
String type
```
      Type to write as
    - bulk
```
Boolean bulk
```
      Index in large or small batches
    - batchSize
```
Long batchSize
```
      Item Count before flush
    - batchBytes
```
Long batchBytes
```
      Number of bytes before flush
    - maxTimeBetweenFlushMs
```
Long maxTimeBetweenFlushMs
```
      Max time between flush (ms)
    - script
```
String script
```
      Script to execute during index
    - tags
```
Tags tags
```
      Tags to apply during index
    - replaceTags
```
Boolean replaceTags
```
      Whether to overwrite _percolator rules on startup
    - cleanupTags
```
Boolean cleanupTags
```
      Whether to remove _percolator rules on shutdown
    - forceUseConfig
```
Boolean forceUseConfig
```
      Whether or not we force the values that are set in the configuration
    - refresh
```
Boolean refresh
```
      Whether to refresh during cleanup
    - additionalProperties
```
Map<K,V> additionalProperties
```
- Class org.apache.streams.elasticsearch.Tags extends Object implements Serializable
  - Serialized Fields
    - additionalProperties
```
Map<K,V> additionalProperties
```
Package org.apache.streams.elasticsearch.processor
- Class org.apache.streams.elasticsearch.processor.DatumFromMetadataAsDocumentProcessor extends Object implements Serializable
  - Serialized Fields
    - elasticsearchClientManager
```
ElasticsearchClientManager elasticsearchClientManager
```
    - config
```
ElasticsearchReaderConfiguration config
```
    - mapper
```
com.fasterxml.jackson.databind.ObjectMapper mapper
```
- Class org.apache.streams.elasticsearch.processor.DatumFromMetadataProcessor extends Object implements Serializable
  - Serialized Fields
    - elasticsearchClientManager
```
ElasticsearchClientManager elasticsearchClientManager
```
    - config
```
ElasticsearchReaderConfiguration config
```
- Class org.apache.streams.elasticsearch.processor.DocumentToMetadataProcessor extends Object implements Serializable
  - Serialized Fields
    - mapper
```
com.fasterxml.jackson.databind.ObjectMapper mapper
```
- Class org.apache.streams.elasticsearch.processor.MetadataFromDocumentProcessor extends Object implements Serializable
  - Serialized Fields
    - mapper
```
com.fasterxml.jackson.databind.ObjectMapper mapper
```
- Class org.apache.streams.elasticsearch.processor.PercolateTagProcessor extends Object implements Serializable
  - Serialized Fields
    - mapper
```
com.fasterxml.jackson.databind.ObjectMapper mapper
```
    - inQueue
```
Queue<E> inQueue
```
    - outQueue
```
Queue<E> outQueue
```
    - config
```
ElasticsearchWriterConfiguration config
```
    - manager
```
ElasticsearchClientManager manager
```
    - bulkBuilder
```
org.elasticsearch.action.bulk.BulkRequestBuilder bulkBuilder
```
    - usePercolateField
```
String usePercolateField
```

Serialized Form

Package org.apache.streams.elasticsearch

Class org.apache.streams.elasticsearch.ElasticsearchConfiguration extends Object implements Serializable

Serialized Fields

hosts

port

clusterName

additionalProperties

Class org.apache.streams.elasticsearch.ElasticsearchPersistDeleter extends ElasticsearchPersistWriter implements Serializable

Class org.apache.streams.elasticsearch.ElasticsearchPersistReader extends Object implements Serializable

Serialized Fields

persistQueue

elasticsearchQuery

config

threadPoolSize

executor

lock

readerTask

Class org.apache.streams.elasticsearch.ElasticsearchPersistUpdater extends ElasticsearchPersistWriter implements Serializable

Class org.apache.streams.elasticsearch.ElasticsearchPersistWriter extends Object implements Serializable

Serialized Fields

affectedIndexes

manager

config

bulkRequest

veryLargeBulk

flushThresholdsRecords

flushThresholdBytes

flushThresholdTime

lastFlush

timer

batchesSent

batchesResponded

currentBatchItems

currentBatchBytes

totalSent

totalSeconds

totalOk

totalFailed

totalSizeInBytes

Class org.apache.streams.elasticsearch.ElasticsearchQuery extends Object implements Serializable

Serialized Fields

elasticsearchClientManager

config

indexes

types

limit

batchSize

scrollTimeout

queryBuilder

search

scrollResp

scrollPositionInScroll

next

totalHits

totalRead

mapper

Class org.apache.streams.elasticsearch.ElasticsearchReaderConfiguration extends ElasticsearchConfiguration implements Serializable

Serialized Fields

indexes

types

scrollTimeout

Search

additionalProperties

Class org.apache.streams.elasticsearch.ElasticsearchWriterConfiguration extends ElasticsearchConfiguration implements Serializable

Serialized Fields

index

type

bulk

batchSize

batchBytes

maxTimeBetweenFlushMs

script

tags

replaceTags

cleanupTags

forceUseConfig

refresh

additionalProperties

Class org.apache.streams.elasticsearch.Tags extends Object implements Serializable