public class SpoutExecutorStats extends CommonStats
rate
Constructor and Description |
---|
SpoutExecutorStats(int rate,
int numStatBuckets) |
Modifier and Type | Method and Description |
---|---|
void |
cleanupStats() |
MultiLatencyStatAndMetric |
getCompleteLatencies() |
ExecutorStats |
renderStats() |
void |
spoutAckedTuple(String stream,
long latencyMs,
com.codahale.metrics.Counter ackedCounter) |
void |
spoutFailedTuple(String stream,
long latencyMs,
com.codahale.metrics.Counter failedCounter) |
emittedTuple, getAcked, getEmitted, getFailed, getRate, getTransferred, transferredTuples, valueStat, valueStat
public MultiLatencyStatAndMetric getCompleteLatencies()
public void cleanupStats()
cleanupStats
in class CommonStats
public void spoutAckedTuple(String stream, long latencyMs, com.codahale.metrics.Counter ackedCounter)
public void spoutFailedTuple(String stream, long latencyMs, com.codahale.metrics.Counter failedCounter)
public ExecutorStats renderStats()
renderStats
in class CommonStats
Copyright © 2022 The Apache Software Foundation. All rights reserved.