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

Class FieldAdditionalValue

java.lang.Object

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

All Implemented Interfaces:

Serializable, IAdditionalValue

public class FieldAdditionalValue
extends Object
implements IAdditionalValue, Serializable

A key value IAdditionalValue that takes its value from a storm tuple.

Author:

dimi

See Also:

Serialized Form

Constructor Summary

Constructors

Constructor and Description
FieldAdditionalValue(String field, String name)

Method Summary

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

Methods inherited from class java.lang.Object

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

Constructor Detail

FieldAdditionalValue

public FieldAdditionalValue(String field,
                            String name)

Parameters:

field - the storm tuple field

name - the json key

Method Detail

getAdditionalValue

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

This method returns a ready to be inserted value

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