本文整理了Java中com.yammer.metrics.core.MetricsRegistry.removeMetric()
方法的一些代码示例,展示了MetricsRegistry.removeMetric()
的具体用法。这些代码示例主要来源于Github
/Stackoverflow
/Maven
等平台,是从一些精选项目中提取出来的代码,具有较强的参考意义,能在一定程度帮忙到你。MetricsRegistry.removeMetric()
方法的具体详情如下:
包路径:com.yammer.metrics.core.MetricsRegistry
类名称:MetricsRegistry
方法名:removeMetric
[英]Removes the metric with the given name.
[中]删除具有给定名称的度量。
代码示例来源:origin: apache/incubator-pinot
/**
* Removes an existing metric
*/
public static void removeMetric(MetricsRegistry registry, MetricName name) {
if (registry != null) {
registry.removeMetric(name);
} else {
Metrics.defaultRegistry().removeMetric(name);
}
}
代码示例来源:origin: lealone/Lealone
public void release() {
Metrics.defaultRegistry().removeMetric(factory.createMetricName("ActiveTasks"));
Metrics.defaultRegistry().removeMetric(factory.createMetricName("PendingTasks"));
Metrics.defaultRegistry().removeMetric(factory.createMetricName("CompletedTasks"));
Metrics.defaultRegistry().removeMetric(factory.createMetricName("TotalBlockedTasks"));
Metrics.defaultRegistry().removeMetric(factory.createMetricName("CurrentlyBlockedTasks"));
}
}
代码示例来源:origin: lealone/Lealone
public void release() {
Metrics.defaultRegistry().removeMetric(factory.createMetricName("ActiveTasks"));
Metrics.defaultRegistry().removeMetric(factory.createMetricName("PendingTasks"));
Metrics.defaultRegistry().removeMetric(factory.createMetricName("CompletedTasks"));
Metrics.defaultRegistry().removeMetric(factory.createMetricName("TotalBlockedTasks"));
Metrics.defaultRegistry().removeMetric(factory.createMetricName("CurrentlyBlockedTasks"));
}
}
代码示例来源:origin: lealone/Lealone
public void release() {
Metrics.defaultRegistry().removeMetric(factory.createMetricName("Timeouts"));
}
}
代码示例来源:origin: com.yammer.metrics/metrics-core
/**
* Removes the metric for the given class with the given name.
*
* @param klass the klass the metric is associated with
* @param name the name of the metric
*/
public void removeMetric(Class<?> klass,
String name) {
removeMetric(klass, name, null);
}
代码示例来源:origin: com.yammer.metrics/metrics-core
/**
* Removes the metric for the given class with the given name and scope.
*
* @param klass the klass the metric is associated with
* @param name the name of the metric
* @param scope the scope of the metric
*/
public void removeMetric(Class<?> klass,
String name,
String scope) {
removeMetric(createName(klass, name, scope));
}
代码示例来源:origin: urbanairship/statshtable
private static void expireOldTimers(MetricsRegistry registry) {
long expireOlderThan = System.currentTimeMillis() - EXPIRE_REGION_TIMERS_MS;
for(Map.Entry<MetricName,Metric> e: registry.allMetrics().entrySet()) {
if(!(e.getValue() instanceof SHTimerMetric)) {
continue;
}
SHTimerMetric metric = (SHTimerMetric)e.getValue();
if(metric.getLastUpdateMillis() < expireOlderThan) {
registry.removeMetric(e.getKey());
}
}
}
代码示例来源:origin: com.facebook.presto.cassandra/cassandra-server
public void release()
{
Metrics.defaultRegistry().removeMetric(factory.createMetricName("CommandPendingTasks"));
Metrics.defaultRegistry().removeMetric(factory.createMetricName("CommandCompletedTasks"));
Metrics.defaultRegistry().removeMetric(factory.createMetricName("CommandDroppedTasks"));
Metrics.defaultRegistry().removeMetric(factory.createMetricName("ResponsePendingTasks"));
Metrics.defaultRegistry().removeMetric(factory.createMetricName("ResponseCompletedTasks"));
Metrics.defaultRegistry().removeMetric(factory.createMetricName("Timeouts"));
}
代码示例来源:origin: com.facebook.presto.cassandra/cassandra-server
public void release()
{
Metrics.defaultRegistry().removeMetric(factory.createMetricName("ActiveTasks"));
Metrics.defaultRegistry().removeMetric(factory.createMetricName("PendingTasks"));
Metrics.defaultRegistry().removeMetric(factory.createMetricName("CompletedTasks"));
Metrics.defaultRegistry().removeMetric(factory.createMetricName("TotalBlockedTasks"));
Metrics.defaultRegistry().removeMetric(factory.createMetricName("CurrentlyBlockedTasks"));
Metrics.defaultRegistry().removeMetric(factory.createMetricName("MaxPoolSize"));
}
}
代码示例来源:origin: com.facebook.presto.cassandra/cassandra-server
public void release()
{
Metrics.defaultRegistry().removeMetric(factory.createMetricName(namePrefix + "Latency"));
Metrics.defaultRegistry().removeMetric(factory.createMetricName(namePrefix + "TotalLatency"));
}
代码示例来源:origin: damienclaveau/kafka-graphite
/**
* Filter gauges that should have been deleted, ugly workaround for KAFKA-1866 with Kafka 0.8.x
* @return {@code false} if gauge is not cleaned.
*/
private boolean cleanInvalidGauge(MetricName name, Metric metric, String metricName) {
try {
metric.processWith(metricProcessor, name, null);
} catch (InvalidGaugeException ex) {
LOGGER.info("Deleting metric {} from registry", metricName);
Metrics.defaultRegistry().removeMetric(name);
return true;
} catch (Exception ex) {
LOGGER.error("Caught an Exception while processing metric " + metricName, ex);
}
return false;
}
代码示例来源:origin: com.facebook.presto.cassandra/cassandra-server
public void release()
{
Metrics.defaultRegistry().removeMetric(factory.createMetricName("ActiveTasks"));
Metrics.defaultRegistry().removeMetric(factory.createMetricName("PendingTasks"));
Metrics.defaultRegistry().removeMetric(factory.createMetricName("CompletedTasks"));
Metrics.defaultRegistry().removeMetric(factory.createMetricName("TotalBlockedTasks"));
Metrics.defaultRegistry().removeMetric(factory.createMetricName("CurrentlyBlockedTasks"));
Metrics.defaultRegistry().removeMetric(factory.createMetricName("MaxPoolSize"));
}
}
代码示例来源:origin: com.facebook.presto.cassandra/cassandra-server
public void release()
{
super.release();
Metrics.defaultRegistry().removeMetric(factory.createMetricName("ContentionHistogram"));
Metrics.defaultRegistry().removeMetric(factory.createMetricName("ConditionNotMet"));
Metrics.defaultRegistry().removeMetric(factory.createMetricName("UnfinishedCommit"));
}
}
代码示例来源:origin: NGDATA/hbase-indexer
public static void shutdownMetrics(String indexerName) {
SortedMap<String, SortedMap<MetricName, Metric>> groupedMetrics = Metrics.defaultRegistry().groupedMetrics(
new IndexerMetricPredicate(indexerName));
for (SortedMap<MetricName, Metric> metricMap : groupedMetrics.values()) {
for (MetricName metricName : metricMap.keySet()) {
Metrics.defaultRegistry().removeMetric(metricName);
}
}
}
代码示例来源:origin: com.facebook.presto.cassandra/cassandra-server
public void release()
{
super.release();
Metrics.defaultRegistry().removeMetric(factory.createMetricName("Timeouts"));
Metrics.defaultRegistry().removeMetric(factory.createMetricName("Unavailables"));
}
}
代码示例来源:origin: com.ngdata/hbase-indexer-common
public static void shutdownMetrics(String indexerName) {
SortedMap<String, SortedMap<MetricName, Metric>> groupedMetrics = Metrics.defaultRegistry().groupedMetrics(
new IndexerMetricPredicate(indexerName));
for (SortedMap<MetricName, Metric> metricMap : groupedMetrics.values()) {
for (MetricName metricName : metricMap.keySet()) {
Metrics.defaultRegistry().removeMetric(metricName);
}
}
}
代码示例来源:origin: com.facebook.presto.cassandra/cassandra-server
/**
* Release all associated metrics.
*/
public void release()
{
for(String name : all)
{
allColumnFamilyMetrics.get(name).remove(Metrics.defaultRegistry().allMetrics().get(factory.createMetricName(name)));
Metrics.defaultRegistry().removeMetric(factory.createMetricName(name));
}
readLatency.release();
writeLatency.release();
rangeLatency.release();
Metrics.defaultRegistry().removeMetric(factory.createMetricName("EstimatedRowSizeHistogram"));
Metrics.defaultRegistry().removeMetric(factory.createMetricName("EstimatedRowCount"));
Metrics.defaultRegistry().removeMetric(factory.createMetricName("EstimatedColumnCountHistogram"));
Metrics.defaultRegistry().removeMetric(factory.createMetricName("KeyCacheHitRate"));
Metrics.defaultRegistry().removeMetric(factory.createMetricName("CoordinatorReadLatency"));
Metrics.defaultRegistry().removeMetric(factory.createMetricName("CoordinatorScanLatency"));
Metrics.defaultRegistry().removeMetric(factory.createMetricName("WaitingOnFreeMemtableSpace"));
}
代码示例来源:origin: wavefrontHQ/java
EvictingMetricsRegistry(long expiryMillis, boolean wavefrontHistograms, Supplier<Long> nowMillis) {
this.metricsRegistry = new MetricsRegistry();
this.nowMillis = nowMillis;
this.wavefrontHistograms = wavefrontHistograms;
this.metricCache = Caffeine.<MetricName, Metric>newBuilder()
.expireAfterAccess(expiryMillis, TimeUnit.MILLISECONDS)
.<MetricName, Metric>removalListener((metricName, metric, reason) -> {
if (metricName == null || metric == null) {
logger.severe("Application error, pulled null key or value from metricCache.");
return;
}
metricsRegistry.removeMetric(metricName);
}).build();
this.metricNamesForMetricMatchers = Caffeine.<MetricMatcher, Set<MetricName>>newBuilder()
.build((metricMatcher) -> Sets.newHashSet());
}
代码示例来源:origin: com.wavefront/proxy
EvictingMetricsRegistry(long expiryMillis, boolean wavefrontHistograms, Supplier<Long> nowMillis) {
this.metricsRegistry = new MetricsRegistry();
this.nowMillis = nowMillis;
this.wavefrontHistograms = wavefrontHistograms;
this.metricCache = Caffeine.<MetricName, Metric>newBuilder()
.expireAfterAccess(expiryMillis, TimeUnit.MILLISECONDS)
.<MetricName, Metric>removalListener((metricName, metric, reason) -> {
if (metricName == null || metric == null) {
logger.severe("Application error, pulled null key or value from metricCache.");
return;
}
metricsRegistry.removeMetric(metricName);
}).build();
this.metricNamesForMetricMatchers = Caffeine.<MetricMatcher, Set<MetricName>>newBuilder()
.build((metricMatcher) -> Sets.newHashSet());
}
代码示例来源:origin: com.facebook.presto.cassandra/cassandra-server
/**
* Release all associated metrics.
*/
public void release()
{
for(String name : allMetrics)
{
Metrics.defaultRegistry().removeMetric(factory.createMetricName(name));
}
// latency metrics contain multiple metrics internally and need to be released manually
readLatency.release();
writeLatency.release();
rangeLatency.release();
}
内容来源于网络,如有侵权,请联系作者删除!