public class BoltExecutorStats extends CommonStats
rate| Constructor and Description |
|---|
BoltExecutorStats(int rate,
int numStatBuckets) |
| Modifier and Type | Method and Description |
|---|---|
void |
boltAckedTuple(String component,
String stream,
long latencyMs) |
void |
boltExecuteTuple(String component,
String stream,
long latencyMs,
long workerUptimeSecs,
Task firstExecutorTask) |
void |
boltFailedTuple(String component,
String stream) |
void |
cleanupStats() |
MultiCountStat |
getExecuted() |
MultiLatencyStat |
getExecuteLatencies() |
MultiLatencyStat |
getProcessLatencies() |
ExecutorStats |
renderStats() |
emittedTuple, getAcked, getEmitted, getFailed, getRate, getTransferred, transferredTuples, valueStat, valueStatpublic MultiCountStat getExecuted()
public MultiLatencyStat getProcessLatencies()
public MultiLatencyStat getExecuteLatencies()
public void cleanupStats()
cleanupStats in class CommonStatspublic void boltExecuteTuple(String component, String stream, long latencyMs, long workerUptimeSecs, Task firstExecutorTask)
public ExecutorStats renderStats()
renderStats in class CommonStatsCopyright © 2021 The Apache Software Foundation. All rights reserved.