org.apache.streams.elasticsearch

Class ElasticsearchPersistDeleter

java.lang.Object

org.apache.streams.elasticsearch.ElasticsearchPersistWriter

org.apache.streams.elasticsearch.ElasticsearchPersistDeleter

All Implemented Interfaces:

Serializable, StreamsOperation, StreamsPersistWriter

public class ElasticsearchPersistDeleter
extends ElasticsearchPersistWriter
implements StreamsPersistWriter

ElasticsearchPersistDeleter deletes documents from 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
ElasticsearchPersistDeleter()
ElasticsearchPersistDeleter(ElasticsearchWriterConfiguration config)

Method Summary

Modifier and Type	Method and Description
void	add(org.elasticsearch.action.delete.DeleteRequest request) Enqueue DeleteRequest.
void	delete(String index, String type, String id) Prepare and en-queue @see org.elasticsearch.action.delete.DeleteRequest
String	getId()
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

ElasticsearchPersistDeleter

public ElasticsearchPersistDeleter()

ElasticsearchPersistDeleter

public ElasticsearchPersistDeleter(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

delete

public void delete(String index,
                   String type,
                   String id)

Prepare and en-queue @see org.elasticsearch.action.delete.DeleteRequest

Parameters:

index - index

type - type

id - id

add

public void add(org.elasticsearch.action.delete.DeleteRequest request)

Enqueue DeleteRequest.

Parameters:

request - request