org.apache.streams.local.counters

Interface StreamsTaskCounterMXBean

All Known Implementing Classes:

StreamsTaskCounter

public interface StreamsTaskCounterMXBean

Method Summary

Modifier and Type	Method and Description
double	getAvgTime() Returns the average time in milliseconds it takes the task to readCurrent, process, or write to return.
double	getErrorRate() Get the error rate of the streams process calculated by the number of errors not handled by the StreamsTask divided by the number of datums received.
long	getMaxTime() Returns the max time in milliseconds it takes the task to readCurrent, process, or write to return.
long	getNumEmitted() Get the number of StreamsDatums emitted by the streams process
long	getNumReceived() Get the number of StreamsDatums received by the streams process
long	getNumUnhandledErrors() Get the number of errors that the process had to catch because the executing Provider/Processor/Writer did not catch and handle the exception

Method Detail

getErrorRate

double getErrorRate()

Get the error rate of the streams process calculated by the number of errors not handled by the StreamsTask divided by the number of datums received.

Returns:

error rate

getNumEmitted

long getNumEmitted()

Get the number of StreamsDatums emitted by the streams process

Returns:

number of emitted datums

getNumReceived

long getNumReceived()

Get the number of StreamsDatums received by the streams process

Returns:

number of received datums

getNumUnhandledErrors

long getNumUnhandledErrors()

Get the number of errors that the process had to catch because the executing Provider/Processor/Writer did not catch and handle the exception

Returns:

number of handled errors

getAvgTime

double getAvgTime()

Returns the average time in milliseconds it takes the task to readCurrent, process, or write to return.

Returns:

getMaxTime

long getMaxTime()

Returns the max time in milliseconds it takes the task to readCurrent, process, or write to return.

Returns: