fact.utils

Class PreviousEventInfo

java.lang.Object

fact.utils.PreviousEventInfo

All Implemented Interfaces:

stream.Processor

public class PreviousEventInfo
extends Object
implements stream.Processor

Field Summary

Fields

Modifier and Type	Field and Description
int	limitEvents
String	outputKey
String	startCellKey
String	unixTimeKey

Constructor Summary

Constructors

Constructor and Description
PreviousEventInfo()

Method Summary

Modifier and Type	Method and Description
stream.Data	process(stream.Data item)

Methods inherited from class java.lang.Object

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

Field Detail

startCellKey

@Parameter(required=true)
public String startCellKey

outputKey

@Parameter(required=true)
public String outputKey

unixTimeKey

@Parameter(required=false,
           description="The key containing the UnixTimeUTC")
public String unixTimeKey

limitEvents

@Parameter(required=false,
           description="Set the amount of events to buffer for the jumpremoval.")
public int limitEvents

Constructor Detail

PreviousEventInfo

public PreviousEventInfo()

Method Detail

process

public stream.Data process(stream.Data item)

Specified by:

process in interface stream.Processor