public class SpoutExecutorStats extends CommonStats
rate| Constructor and Description |
|---|
SpoutExecutorStats(int rate,
int numStatBuckets) |
| Modifier and Type | Method and Description |
|---|---|
void |
cleanupStats() |
MultiLatencyStat |
getCompleteLatencies() |
ExecutorStats |
renderStats() |
void |
spoutAckedTuple(String stream,
long latencyMs) |
void |
spoutFailedTuple(String stream) |
emittedTuple, getAcked, getEmitted, getFailed, getRate, getTransferred, transferredTuples, valueStat, valueStatpublic MultiLatencyStat getCompleteLatencies()
public void cleanupStats()
cleanupStats in class CommonStatspublic void spoutAckedTuple(String stream, long latencyMs)
public void spoutFailedTuple(String stream)
public ExecutorStats renderStats()
renderStats in class CommonStatsCopyright © 2021 The Apache Software Foundation. All rights reserved.