stream.monitor

Class TimeRate

java.lang.Object

stream.AbstractProcessor

stream.monitor.TimeRate

All Implemented Interfaces:

Processor, Service, StatefulProcessor, StatisticsService

public class TimeRate
extends AbstractProcessor
implements StatisticsService

Author:

Hendrik Blom

Field Summary

Fields

Modifier and Type	Field and Description
protected Integer	every
protected String	id
protected String	index
(package private) static org.slf4j.Logger	log
protected Long	nowIndex
protected Double	rate
protected Long	start
protected Long	startIndex

Fields inherited from class stream.AbstractProcessor

context

Constructor Summary

Constructors

Constructor and Description
TimeRate()

Method Summary

Methods

Modifier and Type	Method and Description
void	finish()
Integer	getEvery()
String	getId()
String	getIndex()
private Long	getIndex(Data data)
Statistics	getStatistics()
void	init(ProcessContext ctx)
Data	process(Data data)
void	reset()
void	setEvery(Integer every)
void	setId(String id)
void	setIndex(String index)

Methods inherited from class stream.AbstractProcessor

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

start

protected Long start

startIndex

protected Long startIndex

nowIndex

protected Long nowIndex

rate

protected Double rate

every

protected Integer every

id

protected String id

index

protected String index

Constructor Detail

TimeRate

public TimeRate()

Method Detail

getId

public String getId()

Returns:

the id

setId

public void setId(String id)

Parameters:

id - the id to set

getIndex

public String getIndex()

setIndex

public void setIndex(String index)

init

public void init(ProcessContext ctx)
          throws Exception

Specified by:

init in interface StatefulProcessor

Overrides:

init in class AbstractProcessor

Throws:

Exception

See Also:

AbstractProcessor.init(stream.ProcessContext)

process

public Data process(Data data)

Specified by:

process in interface Processor

getIndex

private Long getIndex(Data data)

finish

public void finish()
            throws Exception

Specified by:

finish in interface StatefulProcessor

Overrides:

finish in class AbstractProcessor

Throws:

Exception

See Also:

AbstractProcessor.finish()

reset

public void reset()
           throws Exception

Specified by:

reset in interface Service

Throws:

Exception

getStatistics

public Statistics getStatistics()

Specified by:

getStatistics in interface StatisticsService

getEvery

public Integer getEvery()

Returns:

the every

setEvery

public void setEvery(Integer every)

Parameters:

every - the every to set