com.yammer.metrics.core.MetricsRegistry.removeMetric()方法的使用及代码示例

x33g5p2x  于2022-01-25 转载在 其他  
字(10.1k)|赞(0)|评价(0)|浏览(142)

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

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();
}

相关文章