org.apache.streams.elasticsearch

Class ElasticsearchPersistUpdater

java.lang.Object

org.apache.streams.elasticsearch.ElasticsearchPersistWriter

org.apache.streams.elasticsearch.ElasticsearchPersistUpdater

All Implemented Interfaces:

Serializable, StreamsOperation, StreamsPersistWriter

public class ElasticsearchPersistUpdater
extends ElasticsearchPersistWriter
implements StreamsPersistWriter

ElasticsearchPersistUpdater updates documents to elasticsearch.

See Also:

Serialized Form

Field Summary

Fields inherited from class org.apache.streams.elasticsearch.ElasticsearchPersistWriter

affectedIndexes, bulkRequest, config, currentBatchBytes, currentBatchItems, manager, OBJECT_MAPPER

Constructor Summary

Constructors

Constructor and Description
ElasticsearchPersistUpdater()
ElasticsearchPersistUpdater(ElasticsearchWriterConfiguration config)

Method Summary

Modifier and Type	Method and Description
void	add(org.elasticsearch.action.update.UpdateRequest request) Enqueue UpdateRequest.
String	getId()
void	update(String indexName, String type, String id, String parent, String routing, String json) Prepare and en-queue.
void	write(StreamsDatum streamsDatum)

Methods inherited from class org.apache.streams.elasticsearch.ElasticsearchPersistWriter

add, add, add, appendMetadata, checkForFlush, checkIndexImplications, cleanUp, createIndexIfMissing, disableRefresh, docAsJson, getAffectedIndexes, getBatchesResponded, getBatchesSent, getFlushThreasholdMaxTime, getFlushThresholdBytes, getFlushThresholdsRecords, getTotalFailed, getTotalOk, getTotalOutstanding, getTotalSeconds, getTotalSent, getTotalSizeInBytes, isConnected, prepare, setFlushThreasholdMaxTime, setFlushThresholdBytes, setFlushThresholdRecords, setVeryLargeBulk

Methods inherited from class java.lang.Object

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

Methods inherited from interface org.apache.streams.core.StreamsOperation

cleanUp, prepare

Constructor Detail

ElasticsearchPersistUpdater

public ElasticsearchPersistUpdater()

ElasticsearchPersistUpdater

public ElasticsearchPersistUpdater(ElasticsearchWriterConfiguration config)

Method Detail

getId

public String getId()

Specified by:

getId in interface StreamsOperation

Overrides:

getId in class ElasticsearchPersistWriter

write

public void write(StreamsDatum streamsDatum)

Specified by:

write in interface StreamsPersistWriter

Overrides:

write in class ElasticsearchPersistWriter

update

public void update(String indexName,
                   String type,
                   String id,
                   String parent,
                   String routing,
                   String json)

Prepare and en-queue.

Parameters:

indexName - indexName

type - type

id - id

parent - parent

routing - routing

json - json

See Also:

UpdateRequest

add

public void add(org.elasticsearch.action.update.UpdateRequest request)

Enqueue UpdateRequest.

Parameters:

request - request