stream.parser

Class ParseTimestamp

java.lang.Object

stream.AbstractProcessor

stream.parser.ParseTimestamp

All Implemented Interfaces:

Processor, StatefulProcessor

public class ParseTimestamp
extends AbstractProcessor

This simple processor adds a timestamp (current time in milliseconds) to all processed data items.

Author:

Christian Bockermann <chris@jwall.org>

Field Summary

Fields

Modifier and Type	Field and Description
(package private) SimpleDateFormat	dateFormat
(package private) String	format
(package private) String	from
(package private) String	key
(package private) static org.slf4j.Logger	log
(package private) String	timezone

Fields inherited from class stream.AbstractProcessor

context

Constructor Summary

Constructors

Constructor and Description
ParseTimestamp()
ParseTimestamp(String key, String format, String from)

Method Summary

Methods

Modifier and Type	Method and Description
String	getFormat()
String	getFrom()
String	getKey()
String	getTimezone()
void	init(ProcessContext ctx)
Data	process(Data data)
void	setFormat(String format)
void	setFrom(String from)
void	setKey(String key)
void	setTimezone(String timezone)

Methods inherited from class stream.AbstractProcessor

finish, resetState

Methods inherited from class java.lang.Object

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

Field Detail

log

static org.slf4j.Logger log

dateFormat

SimpleDateFormat dateFormat

key

String key

format

String format

from

String from

timezone

String timezone

Constructor Detail

ParseTimestamp

public ParseTimestamp()

ParseTimestamp

public ParseTimestamp(String key,
              String format,
              String from)

Method Detail

getTimezone

public String getTimezone()

Returns:

the timezone

setTimezone

@Parameter(required=false,
           description="The timezone that the processed data is assumed to refer to.")
public void setTimezone(String timezone)

Parameters:

timezone -

getKey

public String getKey()

Returns:

the key

setKey

@Parameter
public void setKey(String key)

Parameters:

key - the key to set

getFormat

public String getFormat()

Returns:

the format

setFormat

@Parameter(required=true,
           defaultValue="yyyy-MM-dd HH:mm:ss",
           description="The date format string used for parsing.")
public void setFormat(String format)

Parameters:

format - the format to set

getFrom

public String getFrom()

Returns:

the from

setFrom

@Parameter(required=true,
           description="The key/attribute from which the timestamp should be parsed.")
public void setFrom(String from)

Parameters:

from - the from to set

process

public Data process(Data data)

See Also:

DataProcessor

init

public void init(ProcessContext ctx)
          throws Exception

Specified by:

init in interface StatefulProcessor

Overrides:

init in class AbstractProcessor

Throws:

Exception

See Also:

stream.AbstractProcessor#init()