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

Class DateAdditionalValue

java.lang.Object

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

All Implemented Interfaces:

Serializable, IAdditionalValue

public class DateAdditionalValue
extends Object
implements IAdditionalValue, Serializable

A small utility builder class to efficiently generate a json line containing the current time as a correctly formatted string.

This is used by the elasticsearch bolt to efficiently add timestamp as part of indexed documents.

Author:

dimi

See Also:

Serialized Form

Constructor Summary

Constructors

Constructor and Description
DateAdditionalValue(String format, String name, String tupleField)

Method Summary

Modifier and Type	Method and Description
String	getAdditionalValue(org.apache.storm.tuple.Tuple t) This method returns a ready to be inserted timestamp json line.
String	getKey()

Methods inherited from class java.lang.Object

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

Constructor Detail

DateAdditionalValue

public DateAdditionalValue(String format,
                           String name,
                           String tupleField)

Parameters:

format - the data format. "iso" is accepted.

name - the target elasticsearch document field name

tupleField - the storm input field where to take that date, if null the current time will be used

Method Detail

getAdditionalValue

public String getAdditionalValue(org.apache.storm.tuple.Tuple t)

This method returns a ready to be inserted timestamp json line.

Specified by:

getAdditionalValue in interface IAdditionalValue

Parameters:

t - the tuple

Returns:

the current time formatted according to the provided format

getKey

public String getKey()

Specified by:

getKey in interface IAdditionalValue