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

MetricsRegistry.snapshot介绍

[英]Sample all the mutable metrics and put the snapshot in the builder
[中]对所有可变指标进行采样，并将快照放入生成器中

代码示例

代码示例来源：origin: org.apache.hadoop/hadoop-common

@Override
 public void snapshot(MetricsRecordBuilder rb, boolean all) {
  registry.snapshot(rb, all);
 }
}

代码示例来源：origin: org.apache.hadoop/hadoop-common

void snapshot(MetricsRecordBuilder rb, boolean all) {
 registry.snapshot(rb, all);
}

代码示例来源：origin: org.apache.hadoop/hadoop-common

@Override
 public void getMetrics(MetricsCollector builder, boolean all) {
  registry.snapshot(builder.addRecord(registry.info()), all);
 }
};

代码示例来源：origin: org.apache.hadoop/hadoop-common

@Override
public synchronized void getMetrics(MetricsCollector builder, boolean all) {
 MetricsRecordBuilder rb = builder.addRecord(MS_NAME)
   .addGauge(MsInfo.NumActiveSources, sources.size())
   .addGauge(MsInfo.NumAllSources, allSources.size())
   .addGauge(MsInfo.NumActiveSinks, sinks.size())
   .addGauge(MsInfo.NumAllSinks, allSinks.size());
 for (MetricsSinkAdapter sa : sinks.values()) {
  sa.snapshot(rb, all);
 }
 registry.snapshot(rb, all);
}

代码示例来源：origin: apache/kylin

@Override
public void getMetrics(MetricsCollector collector, boolean all) {
  MetricsRecordBuilder builder = collector.addRecord(recordName);
  if (null != context) {
    builder.setContext(context);
  }
  // Synchronizing here ensures that the dropwizard metrics collection side is excluded from executing
  // at the same time we are pulling elements from the queues.
  synchronized (this) {
    snapshotAllMetrics(builder);
  }
  metrics2Registry.snapshot(builder, all);
}

代码示例来源：origin: apache/accumulo

@Override
public void getMetrics(MetricsCollector collector, boolean all) {
 MetricsRecordBuilder builder = collector.addRecord(RECORD).setContext(CONTEXT);
 registry.snapshot(builder, all);
}

代码示例来源：origin: apache/accumulo

@Override
public void getMetrics(MetricsCollector collector, boolean all) {
 MetricsRecordBuilder builder = collector.addRecord(RECORD).setContext(CONTEXT);
 registry.snapshot(builder, all);
}

代码示例来源：origin: apache/accumulo

@Override
public void getMetrics(MetricsCollector collector, boolean all) {
 MetricsRecordBuilder builder = collector.addRecord(RECORD).setContext(CONTEXT);
 registry.snapshot(builder, all);
}

代码示例来源：origin: apache/accumulo

@Override
 public void getMetrics(MetricsCollector collector, boolean all) {
  MetricsRecordBuilder builder = collector.addRecord(record).setContext(CONTEXT);

  registry.snapshot(builder, all);
 }
}

代码示例来源：origin: apache/accumulo

@Override
public void getMetrics(MetricsCollector collector, boolean all) {
 MetricsRecordBuilder builder = collector.addRecord(RECORD).setContext(CONTEXT);
 snapshot();
 registry.snapshot(builder, all);
 replicationQueueTimeQuantiles.snapshot(builder, all);
 replicationQueueTimeStat.snapshot(builder, all);
}

代码示例来源：origin: ch.cern.hadoop/hadoop-common

@Override
 public void snapshot(MetricsRecordBuilder rb, boolean all) {
  registry.snapshot(rb, all);
 }
}

代码示例来源：origin: com.github.jiayuhan-it/hadoop-common

@Override
 public void snapshot(MetricsRecordBuilder rb, boolean all) {
  registry.snapshot(rb, all);
 }
}

代码示例来源：origin: io.prestosql.hadoop/hadoop-apache

@Override
 public void snapshot(MetricsRecordBuilder rb, boolean all) {
  registry.snapshot(rb, all);
 }
}

代码示例来源：origin: org.apache.accumulo/accumulo-tserver

@Override
public void getMetrics(MetricsCollector collector, boolean all) {
 MetricsRecordBuilder builder = collector.addRecord(RECORD).setContext(CONTEXT);
 registry.snapshot(builder, all);
}

代码示例来源：origin: ch.cern.hadoop/hadoop-common

@Override
 public void getMetrics(MetricsCollector builder, boolean all) {
  registry.snapshot(builder.addRecord(registry.info()), all);
 }
};

代码示例来源：origin: apache/accumulo

@Override
 public void getMetrics(MetricsCollector collector, boolean all) {
  MetricsRecordBuilder builder = collector.addRecord(RECORD).setContext(CONTEXT);

  // Update each MutableMetric with the new value
  snapshot();

  // Add then all to the builder
  registry.snapshot(builder, all);

  // TODO Some day, MetricsRegistry will also support the MetricsGaugeDouble or allow us to
  // instantiate it directly
  builder.addGauge(Interns.info(FILES_PER_TABLET, "Number of files per tablet"),
    util.getAverageFilesPerTablet());
  builder.addGauge(Interns.info(HOLD_TIME, "Time commits held"), util.getHoldTime());
  builder.addGauge(Interns.info(INGEST_RATE, "Ingest rate (entries/sec)"), util.getIngest());
  builder.addGauge(Interns.info(INGEST_BYTE_RATE, "Ingest rate (bytes/sec)"),
    util.getIngestByteRate());
  builder.addGauge(Interns.info(QUERY_RATE, "Query rate (entries/sec)"), util.getQueryRate());
  builder.addGauge(Interns.info(QUERY_BYTE_RATE, "Query rate (bytes/sec)"),
    util.getQueryByteRate());
  builder.addGauge(Interns.info(SCANNED_RATE, "Scanned rate"), util.getScannedRate());
 }
}

代码示例来源：origin: ch.cern.hadoop/hadoop-common

@Override
public synchronized void getMetrics(MetricsCollector builder, boolean all) {
 MetricsRecordBuilder rb = builder.addRecord(MS_NAME)
   .addGauge(MsInfo.NumActiveSources, sources.size())
   .addGauge(MsInfo.NumAllSources, allSources.size())
   .addGauge(MsInfo.NumActiveSinks, sinks.size())
   .addGauge(MsInfo.NumAllSinks, allSinks.size());
 for (MetricsSinkAdapter sa : sinks.values()) {
  sa.snapshot(rb, all);
 }
 registry.snapshot(rb, all);
}

代码示例来源：origin: org.apache.hadoop/hadoop-azure

@Override
 public void getMetrics(MetricsCollector builder, boolean all) {
  averageBlockDownloadLatencyMs.set(
    currentBlockDownloadLatency.getCurrentAverage());
  averageBlockUploadLatencyMs.set(
    currentBlockUploadLatency.getCurrentAverage());
  registry.snapshot(builder.addRecord(registry.info().name()), true);
 }
}

代码示例来源：origin: com.github.jiayuhan-it/hadoop-common

@Test public void testMutableRates() {
 MetricsRecordBuilder rb = mockMetricsRecordBuilder();
 MetricsRegistry registry = new MetricsRegistry("test");
 MutableRates rates = new MutableRates(registry);
 rates.init(TestProtocol.class);
 registry.snapshot(rb, false);
 assertCounter("FooNumOps", 0L, rb);
 assertGauge("FooAvgTime", 0.0, rb);
 assertCounter("BarNumOps", 0L, rb);
 assertGauge("BarAvgTime", 0.0, rb);
}

代码示例来源：origin: ch.cern.hadoop/hadoop-common

@Override
 public void getMetrics(MetricsCollector collector, boolean all) {
  collector.addRecord("foo")
        .setContext("foocontext")
        .addCounter(info("C1", "C1 desc"), 1)
        .endRecord()
       .addRecord("bar")
        .setContext("barcontext")
        .addGauge(info("G1", "G1 desc"), 1);
  registry.snapshot(collector.addRecord(registry.info()), all);
 }
}