本文整理了Java中com.yammer.metrics.core.Histogram.clear()
方法的一些代码示例,展示了Histogram.clear()
的具体用法。这些代码示例主要来源于Github
/Stackoverflow
/Maven
等平台,是从一些精选项目中提取出来的代码,具有较强的参考意义,能在一定程度帮忙到你。Histogram.clear()
方法的具体详情如下:
包路径:com.yammer.metrics.core.Histogram
类名称:Histogram
方法名:clear
[英]Clears all recorded values.
[中]清除所有记录的值。
代码示例来源:origin: com.yammer.metrics/metrics-core
/**
* Creates a new {@link Histogram} with the given sample.
*
* @param sample the sample to create a histogram from
*/
Histogram(Sample sample) {
this.sample = sample;
clear();
}
代码示例来源:origin: com.yammer.metrics/metrics-core
/**
* Clears all recorded durations.
*/
public void clear() {
histogram.clear();
}
代码示例来源:origin: io.netty/netty-metrics-yammer
@Override
public void reset() {
delegate.clear();
}
代码示例来源:origin: com.wavefront/proxy
@Override
public Double value() {
Double maxValue = receivedBurstRateHistogram.max();
receivedBurstRateHistogram.clear();
return maxValue;
}
});
代码示例来源:origin: wavefrontHQ/java
@Override
public Double value() {
Double maxValue = receivedBurstRateHistogram.max();
receivedBurstRateHistogram.clear();
return maxValue;
}
});
代码示例来源:origin: wavefrontHQ/java
private void internalProcessYammerHistogram(Histogram histogram, Context context) throws Exception {
final JsonGenerator json = context.json;
json.writeStartObject();
{
json.writeNumberField("count", histogram.count());
writeSummarizable(histogram, json);
writeSampling(histogram, json);
if (context.showFullSamples) {
json.writeObjectField("values", histogram.getSnapshot().getValues());
}
if (clear) histogram.clear();
}
json.writeEndObject();
}
代码示例来源:origin: com.wavefront/java-lib
private void internalProcessYammerHistogram(Histogram histogram, Context context) throws Exception {
final JsonGenerator json = context.json;
json.writeStartObject();
{
json.writeNumberField("count", histogram.count());
writeSummarizable(histogram, json);
writeSampling(histogram, json);
if (context.showFullSamples) {
json.writeObjectField("values", histogram.getSnapshot().getValues());
}
if (clear) histogram.clear();
}
json.writeEndObject();
}
代码示例来源:origin: wavefrontHQ/java
@Override
public void processHistogram(MetricName name, Histogram histogram, Void context) throws Exception {
if (histogram instanceof WavefrontHistogram) {
WavefrontHistogram wavefrontHistogram = (WavefrontHistogram) histogram;
List<WavefrontHistogram.MinuteBin> bins = wavefrontHistogram.bins(clear);
if (bins.isEmpty()) return; // don't send empty histograms.
for (WavefrontHistogram.MinuteBin minuteBin : bins) {
StringBuilder sb = new StringBuilder();
sb.append("!M ").append(minuteBin.getMinMillis() / 1000);
for (Centroid c : minuteBin.getDist().centroids()) {
sb.append(" #").append(c.count()).append(" ").append(c.mean());
}
sb.append(" \"").append(getName(name)).append("\"").append(tagsForMetricName(name)).append("\n");
histogramsSocket.write(sb.toString());
}
} else {
if (!sendEmptyHistograms && histogram.count() == 0) {
// send count still but skip the others.
writeMetric(name, "count", 0);
} else {
writeMetric(name, "count", histogram.count());
writeSampling(name, histogram);
writeSummarizable(name, histogram);
if (clear) histogram.clear();
}
}
}
代码示例来源:origin: wavefrontHQ/java
@Override
public void processHistogram(MetricName name, Histogram histogram, FlushProcessorContext context) throws Exception {
if (histogram instanceof WavefrontHistogram && useWavefrontHistograms) {
WavefrontHistogram wavefrontHistogram = (WavefrontHistogram) histogram;
wavefront.report.Histogram.Builder builder = wavefront.report.Histogram.newBuilder();
builder.setBins(Lists.newLinkedList());
builder.setCounts(Lists.newLinkedList());
long minMillis = Long.MAX_VALUE;
if (wavefrontHistogram.count() == 0) return;
for (WavefrontHistogram.MinuteBin minuteBin : wavefrontHistogram.bins(true)) {
builder.getBins().add(minuteBin.getDist().quantile(.5));
builder.getCounts().add(Math.toIntExact(minuteBin.getDist().size()));
minMillis = Long.min(minMillis, minuteBin.getMinMillis());
}
builder.setType(HistogramType.TDIGEST);
builder.setDuration(Math.toIntExact(currentMillis.get() - minMillis));
context.report(builder.build());
} else {
context.reportSubMetric(histogram.count(), "count");
for (Map.Entry<String, Double> entry : MetricsToTimeseries.explodeSummarizable(histogram, reportEmptyHistogramStats).entrySet()) {
context.reportSubMetric(entry.getValue(), entry.getKey());
}
for (Map.Entry<String, Double> entry : MetricsToTimeseries.explodeSampling(histogram, reportEmptyHistogramStats).entrySet()) {
context.reportSubMetric(entry.getValue(), entry.getKey());
}
histogram.clear();
}
sentCounter.inc();
}
代码示例来源:origin: com.wavefront/proxy
@Override
public void processHistogram(MetricName name, Histogram histogram, FlushProcessorContext context) throws Exception {
if (histogram instanceof WavefrontHistogram && useWavefrontHistograms) {
WavefrontHistogram wavefrontHistogram = (WavefrontHistogram) histogram;
wavefront.report.Histogram.Builder builder = wavefront.report.Histogram.newBuilder();
builder.setBins(Lists.newLinkedList());
builder.setCounts(Lists.newLinkedList());
long minMillis = Long.MAX_VALUE;
if (wavefrontHistogram.count() == 0) return;
for (WavefrontHistogram.MinuteBin minuteBin : wavefrontHistogram.bins(true)) {
builder.getBins().add(minuteBin.getDist().quantile(.5));
builder.getCounts().add(Math.toIntExact(minuteBin.getDist().size()));
minMillis = Long.min(minMillis, minuteBin.getMinMillis());
}
builder.setType(HistogramType.TDIGEST);
builder.setDuration(Math.toIntExact(currentMillis.get() - minMillis));
context.report(builder.build());
} else {
context.reportSubMetric(histogram.count(), "count");
for (Map.Entry<String, Double> entry : MetricsToTimeseries.explodeSummarizable(histogram, reportEmptyHistogramStats).entrySet()) {
context.reportSubMetric(entry.getValue(), entry.getKey());
}
for (Map.Entry<String, Double> entry : MetricsToTimeseries.explodeSampling(histogram, reportEmptyHistogramStats).entrySet()) {
context.reportSubMetric(entry.getValue(), entry.getKey());
}
histogram.clear();
}
sentCounter.inc();
}
内容来源于网络,如有侵权,请联系作者删除!