stream.monitor

Class DataRate

java.lang.Object

stream.AbstractProcessor

stream.monitor.DataRate

All Implemented Interfaces:

Processor, Service, StatefulProcessor, StatisticsService

public class DataRate
extends AbstractProcessor
implements StatisticsService

Field Summary

Fields

Modifier and Type	Field and Description
(package private) String	clock
(package private) Long	count
(package private) Double	elapsed
(package private) Integer	every
(package private) DecimalFormat	fmt
(package private) String	id
(package private) String	key
(package private) Long	last
(package private) static org.slf4j.Logger	log
(package private) Double	rate
(package private) Long	start
(package private) Long	windowCount

Fields inherited from class stream.AbstractProcessor

context

Constructor Summary

Constructors

Constructor and Description
DataRate()

Method Summary

Methods

Modifier and Type	Method and Description
void	finish()
String	getClock()
Integer	getEvery()
String	getId()
String	getKey()
Statistics	getStatistics()
void	init(ProcessContext ctx)
void	printDataRate()
protected void	printDataRate(Long now)
Data	process(Data input)
void	reset()
void	setClock(String clock)
void	setEvery(Integer every)
void	setId(String id)
void	setKey(String key)

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

fmt

final DecimalFormat fmt

log

static org.slf4j.Logger log

clock

String clock

count

Long count

start

Long start

windowCount

Long windowCount

last

Long last

elapsed

Double elapsed

rate

Double rate

every

Integer every

key

String key

id

String id

Constructor Detail

DataRate

public DataRate()

Method Detail

getId

public String getId()

Returns:

the id

setId

public void setId(String id)

Parameters:

id - the id to set

getClock

public String getClock()

setClock

public void setClock(String clock)

getKey

public String getKey()

Returns:

the key

setKey

public void setKey(String key)

Parameters:

key - the key to set

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 input)

Specified by:

process in interface Processor

printDataRate

public void printDataRate()

printDataRate

protected void printDataRate(Long now)

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