public abstract class CommonStats extends Object
Modifier and Type | Field and Description |
---|---|
protected int |
rate |
Constructor and Description |
---|
CommonStats(int rate,
int numStatBuckets) |
Modifier and Type | Method and Description |
---|---|
void |
cleanupStats() |
void |
emittedTuple(String stream) |
MultiCountStat |
getAcked() |
MultiCountStat |
getEmitted() |
MultiCountStat |
getFailed() |
int |
getRate() |
MultiCountStat |
getTransferred() |
abstract ExecutorStats |
renderStats() |
void |
transferredTuples(String stream,
int amount) |
protected Map<String,Map<String,Long>> |
valueStat(MultiCountStat metric) |
protected Map<String,Map<String,Double>> |
valueStat(MultiLatencyStat metric) |
public MultiCountStat getFailed()
public MultiCountStat getAcked()
public int getRate()
public MultiCountStat getEmitted()
public MultiCountStat getTransferred()
public void emittedTuple(String stream)
public void transferredTuples(String stream, int amount)
public void cleanupStats()
public abstract ExecutorStats renderStats()
Copyright © 2023 The Apache Software Foundation. All rights reserved.