org.thales.punch.libraries.storm.bolt.elasticsearch

Class ElasticDocument

java.lang.Object

org.thales.punch.libraries.storm.bolt.elasticsearch.ElasticDocument

public class ElasticDocument
extends Object

A transient data structure to hold a document in the pipe to be sent to elasticsearch

Author:

dimi

Constructor Summary

Constructors

Constructor and Description
ElasticDocument(org.apache.storm.tuple.Tuple tuple, String index, String type, String id, String payload)

Method Summary

Modifier and Type	Method and Description
String	getErrorDocument(String errorTimestampKey, String errorCauseKey, String date)
String	getId()
String	getIndex()
String	getPayload()
org.apache.storm.tuple.Tuple	getTuple()
String	getType()
ElasticDocument	setError(String failureMessage)

Methods inherited from class java.lang.Object

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

Constructor Detail

ElasticDocument

public ElasticDocument(org.apache.storm.tuple.Tuple tuple,
                       String index,
                       String type,
                       String id,
                       String payload)

Parameters:

tuple - the incoming tuple

index - the target index

type - the document type

id - the document id

payload - the document content

Method Detail

getPayload

public String getPayload()

Returns:

the document content

setError

public ElasticDocument setError(String failureMessage)

getType

public String getType()

getId

public String getId()

getIndex

public String getIndex()

getTuple

public org.apache.storm.tuple.Tuple getTuple()

getErrorDocument

public String getErrorDocument(String errorTimestampKey,
                               String errorCauseKey,
                               String date)