com.yammer.metrics.core.Meter类的使用及代码示例

本文整理了Java中com.yammer.metrics.core.Meter类的一些代码示例，展示了Meter类的具体用法。这些代码示例主要来源于Github/Stackoverflow/Maven等平台，是从一些精选项目中提取出来的代码，具有较强的参考意义，能在一定程度帮忙到你。Meter类的具体详情如下：
包路径：com.yammer.metrics.core.Meter
类名称：Meter

Meter介绍

[英]A meter metric which measures mean throughput and one-, five-, and fifteen-minute exponentially-weighted moving average throughputs.
[中]测量平均吞吐量和1分钟、5分钟和15分钟指数加权移动平均吞吐量的计量单位。

代码示例

代码示例来源：origin: lealone/Lealone

void incrementTimeout() {
metrics.timeouts.mark();
}

代码示例来源：origin: lealone/Lealone

@Override
public long getTotalTimeouts() {
return ConnectionMetrics.totalTimeouts.count();
}

代码示例来源：origin: addthis/hydra

public QueryEngineDirectory(DataTree tree, String dir) {
super(tree);
this.dir = dir;
currentlyOpenEngines.inc();
engineCreations.mark(); //Metric for total trees/engines initialized
}

代码示例来源：origin: org.apache.giraph/giraph-core

++inputSplitEdgesFiltered;
if (inputSplitEdgesFiltered % EDGES_FILTERED_UPDATE_PERIOD == 0) {
totalEdgesFiltered.inc(inputSplitEdgesFiltered);
inputSplitEdgesFiltered = 0;
totalEdgesMeter.mark(EDGES_UPDATE_PERIOD);
WorkerProgress.get().addEdgesLoaded(EDGES_UPDATE_PERIOD);
LoggerUtils.setStatusAndLog(context, LOG, Level.INFO,
"readEdgeInputSplit: Loaded " +
totalEdgesMeter.count() + " edges at " +
totalEdgesMeter.meanRate() + " edges/sec " +
MemoryUtils.getRuntimeMemoryStats());
totalEdgesFiltered.inc(inputSplitEdgesFiltered);
totalEdgesMeter.mark(inputSplitEdgesLoaded % EDGES_UPDATE_PERIOD);

代码示例来源：origin: addthis/MetricCatcher

} else if (metric instanceof Counter) {
if (value > 0) {
((Counter) metric).inc((long) value);
} else if (value <0) {
((Counter) metric).dec((long) value * -1);
} else {
((Counter) metric).clear();
((Meter) metric).mark((long) value);
} else if (metric instanceof Histogram) {

代码示例来源：origin: NGDATA/hbase-indexer

private void copyIndexingMetricsToCounters(Context context) {
final String COUNTER_GROUP = "HBase Indexer Metrics";
SortedMap> groupedMetrics = Metrics.defaultRegistry().groupedMetrics(
new IndexerMetricsUtil.IndexerMetricPredicate());
for (Entry> metricsGroupEntry : groupedMetrics.entrySet()) {
SortedMap metricsGroupMap = metricsGroupEntry.getValue();
for (Entry metricEntry : metricsGroupMap.entrySet()) {
MetricName metricName = metricEntry.getKey();
Metric metric = metricEntry.getValue();
String counterName = metricName.getType() + ": " + metricName.getName();
if (metric instanceof Counter) {
Counter counter = (Counter) metric;
context.getCounter(COUNTER_GROUP, counterName).increment(counter.count());
} else if (metric instanceof Meter) {
Meter meter = (Meter) metric;
context.getCounter(COUNTER_GROUP, counterName).increment(meter.count());
} else if (metric instanceof Timer) {
Timer timer = (Timer) metric;
context.getCounter(COUNTER_GROUP, counterName).increment((long) timer.sum());
}
}
}
}

代码示例来源：origin: com.ebay.jetstream/jetstream-messaging

public MeterPOJO(Meter m) {
count = m.count();
fifteenMinuteRate = m.fifteenMinuteRate();
fiveMinuteRate = m.fiveMinuteRate();
meanRate = m.meanRate();
rateUnit = m.rateUnit().toString();
OneMinuteRate= m.oneMinuteRate();
}

代码示例来源：origin: addthis/hydra

private void emitTaskExitState() {
if (emitTaskState) {
try {
TaskExitState exitState = new TaskExitState();
exitState.setInput(inputMeter.count());
exitState.setTotalEmitted(outputMeter.count());
exitState.setMeanRate(outputMeter.meanRate());
Files.write(CodecJSON.INSTANCE.encode(exitState), new File("job.exit"));
} catch (Exception ex) {
log.error("", ex);
}
}
}

代码示例来源：origin: addthis/hydra

lastTick = time;
double inputRateAtTick = inputMeter.oneMinuteRate();
long inputCountAtTick = inputMeter.count();
long inputCountForTick = inputCountAtTick - lastInputCount;
lastInputCount = inputCountAtTick;
double outputRateAtTick = outputMeter.oneMinuteRate();
long outputCountAtTick = outputMeter.count();
long outputCountForTick = outputCountAtTick - lastOutputCount;
lastOutputCount = outputCountAtTick;

代码示例来源：origin: com.yammer.metrics/metrics-core

@Override
public double meanRate() {
if (count() == 0) {
return 0.0;
} else {
final long elapsed = (clock.tick() - startTime);
return convertNsRate(count() / (double) elapsed);
}
}

代码示例来源：origin: com.yammer.metrics/metrics-core

@Override
public double meanRate() {
return meter.meanRate();
}

代码示例来源：origin: com.yammer.metrics/metrics-core

@Override
public double fifteenMinuteRate() {
return meter.fifteenMinuteRate();
}

代码示例来源：origin: com.yammer.metrics/metrics-core

@Override
public double oneMinuteRate() {
return meter.oneMinuteRate();
}

代码示例来源：origin: addthis/hydra

private void jobTaskUpdateHeartbeatCheck() {
try {
String now = Long.toString(System.currentTimeMillis());
spawnDataStore.put(SpawnDataStoreKeys.SPAWN_JOB_CONFIG_HEARTBEAT_PATH, now);
String received = spawnDataStore.get(SpawnDataStoreKeys.SPAWN_JOB_CONFIG_HEARTBEAT_PATH);
if (Objects.equals(received, now)) {
SpawnMetrics.jobTaskUpdateHeartbeatSuccessMeter.mark();
} else {
SpawnMetrics.jobTaskUpdateHeartbeatFailureCounter.inc();
}
} catch (Exception e) {
SpawnMetrics.jobTaskUpdateHeartbeatFailureCounter.inc();
log.warn("Failed to perform jobtaskupdate heartbeat check", e);
}
}

代码示例来源：origin: org.apache.giraph/giraph-core

++inputSplitVerticesFiltered;
if (inputSplitVerticesFiltered % VERTICES_FILTERED_UPDATE_PERIOD == 0) {
totalVerticesFilteredCounter.inc(inputSplitVerticesFiltered);
inputSplitVerticesFiltered = 0;
totalVerticesMeter.mark(VERTICES_UPDATE_PERIOD);
WorkerProgress.get().addVerticesLoaded(VERTICES_UPDATE_PERIOD);
totalEdgesMeter.mark(edgesSinceLastUpdate);
inputSplitEdgesLoaded += edgesSinceLastUpdate;
edgesSinceLastUpdate = 0;
context, LOG, Level.INFO,
"readVertexInputSplit: Loaded " +
totalVerticesMeter.count() + " vertices at " +
totalVerticesMeter.meanRate() + " vertices/sec " +
totalEdgesMeter.count() + " edges at " +
totalEdgesMeter.meanRate() + " edges/sec " +
MemoryUtils.getRuntimeMemoryStats());
totalVerticesMeter.mark(inputSplitVerticesLoaded % VERTICES_UPDATE_PERIOD);
totalEdgesMeter.mark(edgesSinceLastUpdate);
totalVerticesFilteredCounter.inc(inputSplitVerticesFiltered);

代码示例来源：origin: com.ngdata/hbase-indexer-mr

private void copyIndexingMetricsToCounters(Context context) {
final String COUNTER_GROUP = "HBase Indexer Metrics";
SortedMap> groupedMetrics = Metrics.defaultRegistry().groupedMetrics(
new IndexerMetricsUtil.IndexerMetricPredicate());
for (Entry> metricsGroupEntry : groupedMetrics.entrySet()) {
SortedMap metricsGroupMap = metricsGroupEntry.getValue();
for (Entry metricEntry : metricsGroupMap.entrySet()) {
MetricName metricName = metricEntry.getKey();
Metric metric = metricEntry.getValue();
String counterName = metricName.getType() + ": " + metricName.getName();
if (metric instanceof Counter) {
Counter counter = (Counter) metric;
context.getCounter(COUNTER_GROUP, counterName).increment(counter.count());
} else if (metric instanceof Meter) {
Meter meter = (Meter) metric;
context.getCounter(COUNTER_GROUP, counterName).increment(meter.count());
} else if (metric instanceof Timer) {
Timer timer = (Timer) metric;
context.getCounter(COUNTER_GROUP, counterName).increment((long) timer.sum());
}
}
}
}

代码示例来源：origin: addthis/hydra

@Test
public void reportsMeterValues() throws Exception {
final Meter meter = mock(Meter.class);
when(meter.eventType()).thenReturn("events");
when(meter.rateUnit()).thenReturn(TimeUnit.SECONDS);
when(meter.count()).thenReturn(1L);
when(meter.meanRate()).thenReturn(2.0);
when(meter.oneMinuteRate()).thenReturn(3.0);
when(meter.fiveMinuteRate()).thenReturn(4.0);
when(meter.fifteenMinuteRate()).thenReturn(5.0);
reporter.processMeter(name("meter"), meter, null);
verify(output).send(decode("name = t.test.meter.count, value = 1, group = metered, units = events"));
verify(output).send(decode("name = t.test.meter.meanRate, value = 2.0, group = metered, units = events/second"));
verify(output).send(decode("name = t.test.meter.1MinuteRate, value = 3.0, group = metered, units = events/second"));
verify(output).send(decode("name = t.test.meter.5MinuteRate, value = 4.0, group = metered, units = events/second"));
verify(output).send(decode("name = t.test.meter.15MinuteRate, value = 5.0, group = metered, units = events/second"));
}

代码示例来源：origin: com.wavefront/proxy

/**
* @return bytes per minute for requests submissions. Null if no data is available yet.
*/
@Nullable
public Long getBytesPerMinute() {
if (resultPostingMeter.fifteenMinuteRate() == 0 || resultPostingSizes.mean() == 0 || resultPostingSizes.count() <
50) {
return null;
}
return (long) (resultPostingSizes.mean() * resultPostingMeter.fifteenMinuteRate());
}

代码示例来源：origin: com.facebook.presto.cassandra/cassandra-server

public void finishCompaction(CompactionInfo.Holder ci)
{
// notify
ci.finished();
compactions.remove(ci);
bytesCompacted.inc(ci.getCompactionInfo().getTotal());
totalCompactionsCompleted.mark();
}

代码示例来源：origin: lealone/Lealone

public void incrementDroppedMessages(Verb verb) {
assert DROPPABLE_VERBS.contains(verb) : "Verb " + verb + " should not legally be dropped";
droppedMessages.get(verb).dropped.mark();
}