public interface StreamsTaskCounterMXBean
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
StreamsDatum s emitted by the streams process |
long |
getNumReceived()
Get the number of
StreamsDatum s 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
|
double getErrorRate()
StreamsTask
divided by the number of datums received.long getNumEmitted()
StreamsDatum
s emitted by the streams processlong getNumReceived()
StreamsDatum
s received by the streams processlong getNumUnhandledErrors()
double getAvgTime()
long getMaxTime()
Copyright © 2017 The Apache Software Foundation. All rights reserved.