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

YammerHistogramUtils介绍

[英]Utility functions for working with Yammer Metrics.
[中]用于处理Yammer度量的实用函数。

代码示例

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

/** Compute the mean of the given {@code stat} from a timing results. */
private static double calcMean(String desc, Stat stat, List<TimingResult> results) {
 double sum = 0;
 int count = 0;
 for (TimingResult tr : results) {
  for (PerformanceEvaluation.RunResult r : tr.results) {
   assertNotNull("One of the run results is missing detailed run data.", r.hist);
   sum += stat.apply(r.hist);
   count += 1;
   LOG.debug(desc + "{" + YammerHistogramUtils.getHistogramReport(r.hist) + "}");
  }
 }
 return sum / count;
}

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

/**
 * @return Subset of the histograms' calculation.
 */
public String getShortValueSizeReport() {
 return YammerHistogramUtils.getShortHistogramReport(this.valueSizeHistogram);
}

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

void testSetup() throws IOException {
 // test metrics
 latencyHistogram = YammerHistogramUtils.newHistogram(new UniformReservoir(1024 * 500));
 valueSizeHistogram = YammerHistogramUtils.newHistogram(new UniformReservoir(1024 * 500));
 // scan metrics
 rpcCallsHistogram = YammerHistogramUtils.newHistogram(new UniformReservoir(1024 * 500));
 remoteRpcCallsHistogram = YammerHistogramUtils.newHistogram(new UniformReservoir(1024 * 500));
 millisBetweenNextHistogram = YammerHistogramUtils.newHistogram(new UniformReservoir(1024 * 500));
 regionsScannedHistogram = YammerHistogramUtils.newHistogram(new UniformReservoir(1024 * 500));
 bytesInResultsHistogram = YammerHistogramUtils.newHistogram(new UniformReservoir(1024 * 500));
 bytesInRemoteResultsHistogram = YammerHistogramUtils.newHistogram(new UniformReservoir(1024 * 500));
 onStartup();
}

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

status.setStatus("Latency (us) : " + YammerHistogramUtils.getHistogramReport(
  latencyHistogram));
status.setStatus("Num measures (latency) : " + latencyHistogram.getCount());
status.setStatus(YammerHistogramUtils.getPrettyHistogramReport(latencyHistogram));
if (valueSizeHistogram.getCount() > 0) {
 status.setStatus("ValueSize (bytes) : "
   + YammerHistogramUtils.getHistogramReport(valueSizeHistogram));
 status.setStatus("Num measures (ValueSize): " + valueSizeHistogram.getCount());
 status.setStatus(YammerHistogramUtils.getPrettyHistogramReport(valueSizeHistogram));
} else {
 status.setStatus("No valueSize statistics available");
   YammerHistogramUtils.getHistogramReport(rpcCallsHistogram));
   YammerHistogramUtils.getHistogramReport(remoteRpcCallsHistogram));
   YammerHistogramUtils.getHistogramReport(millisBetweenNextHistogram));
   YammerHistogramUtils.getHistogramReport(regionsScannedHistogram));
   YammerHistogramUtils.getHistogramReport(bytesInResultsHistogram));
   YammerHistogramUtils.getHistogramReport(bytesInRemoteResultsHistogram));

代码示例来源：origin: com.aliyun.hbase/alihbase-mapreduce

void testTakedown() throws IOException {
 onTakedown();
 // Print all stats for this thread continuously.
 // Synchronize on Test.class so different threads don't intermingle the
 // output. We can't use 'this' here because each thread has its own instance of Test class.
 synchronized (Test.class) {
  status.setStatus("Test : " + testName + ", Thread : " + Thread.currentThread().getName());
  status.setStatus("Latency (us) : " + YammerHistogramUtils.getHistogramReport(
    latencyHistogram));
  status.setStatus("Num measures (latency) : " + latencyHistogram.getCount());
  status.setStatus(YammerHistogramUtils.getPrettyHistogramReport(latencyHistogram));
  status.setStatus("ValueSize (bytes) : "
    + YammerHistogramUtils.getHistogramReport(valueSizeHistogram));
  status.setStatus("Num measures (ValueSize): " + valueSizeHistogram.getCount());
  status.setStatus(YammerHistogramUtils.getPrettyHistogramReport(valueSizeHistogram));
 }
 closeConnection();
 receiverHost.closeReceivers();
}

代码示例来源：origin: org.apache.hbase/hbase-mapreduce

status.setStatus("Latency (us) : " + YammerHistogramUtils.getHistogramReport(
  latencyHistogram));
status.setStatus("Num measures (latency) : " + latencyHistogram.getCount());
status.setStatus(YammerHistogramUtils.getPrettyHistogramReport(latencyHistogram));
if (valueSizeHistogram.getCount() > 0) {
 status.setStatus("ValueSize (bytes) : "
   + YammerHistogramUtils.getHistogramReport(valueSizeHistogram));
 status.setStatus("Num measures (ValueSize): " + valueSizeHistogram.getCount());
 status.setStatus(YammerHistogramUtils.getPrettyHistogramReport(valueSizeHistogram));
} else {
 status.setStatus("No valueSize statistics available");
   YammerHistogramUtils.getHistogramReport(rpcCallsHistogram));
   YammerHistogramUtils.getHistogramReport(remoteRpcCallsHistogram));
   YammerHistogramUtils.getHistogramReport(millisBetweenNextHistogram));
   YammerHistogramUtils.getHistogramReport(regionsScannedHistogram));
   YammerHistogramUtils.getHistogramReport(bytesInResultsHistogram));
   YammerHistogramUtils.getHistogramReport(bytesInRemoteResultsHistogram));

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

/**
 * @return Subset of the histograms' calculation.
 */
public String getShortLatencyReport() {
 return YammerHistogramUtils.getShortHistogramReport(this.latencyHistogram);
}

代码示例来源：origin: org.apache.hbase/hbase-it

/** Compute the mean of the given {@code stat} from a timing results. */
private static double calcMean(String desc, Stat stat, List<TimingResult> results) {
 double sum = 0;
 int count = 0;
 for (TimingResult tr : results) {
  for (PerformanceEvaluation.RunResult r : tr.results) {
   assertNotNull("One of the run results is missing detailed run data.", r.hist);
   sum += stat.apply(r.hist);
   count += 1;
   LOG.debug(desc + "{" + YammerHistogramUtils.getHistogramReport(r.hist) + "}");
  }
 }
 return sum / count;
}

代码示例来源：origin: org.apache.hbase/hbase-mapreduce

void testSetup() throws IOException {
 // test metrics
 latencyHistogram = YammerHistogramUtils.newHistogram(new UniformReservoir(1024 * 500));
 valueSizeHistogram = YammerHistogramUtils.newHistogram(new UniformReservoir(1024 * 500));
 // scan metrics
 rpcCallsHistogram = YammerHistogramUtils.newHistogram(new UniformReservoir(1024 * 500));
 remoteRpcCallsHistogram = YammerHistogramUtils.newHistogram(new UniformReservoir(1024 * 500));
 millisBetweenNextHistogram = YammerHistogramUtils.newHistogram(new UniformReservoir(1024 * 500));
 regionsScannedHistogram = YammerHistogramUtils.newHistogram(new UniformReservoir(1024 * 500));
 bytesInResultsHistogram = YammerHistogramUtils.newHistogram(new UniformReservoir(1024 * 500));
 bytesInRemoteResultsHistogram = YammerHistogramUtils.newHistogram(new UniformReservoir(1024 * 500));
 onStartup();
}

代码示例来源：origin: com.aliyun.hbase/alihbase-mapreduce

/**
 * @return Subset of the histograms' calculation.
 */
public String getShortLatencyReport() {
 return YammerHistogramUtils.getShortHistogramReport(this.latencyHistogram);
}

代码示例来源：origin: com.aliyun.hbase/alihbase-mapreduce

void testSetup() throws IOException {
 createConnection();
 onStartup();
 latencyHistogram = YammerHistogramUtils.newHistogram(new UniformReservoir(1024 * 500));
 valueSizeHistogram = YammerHistogramUtils.newHistogram(new UniformReservoir(1024 * 500));
}

代码示例来源：origin: com.aliyun.hbase/alihbase-mapreduce

/**
 * @return Subset of the histograms' calculation.
 */
public String getShortValueSizeReport() {
 return YammerHistogramUtils.getShortHistogramReport(this.valueSizeHistogram);
}

代码示例来源：origin: org.apache.hbase/hbase-mapreduce

/**
 * @return Subset of the histograms' calculation.
 */
public String getShortLatencyReport() {
 return YammerHistogramUtils.getShortHistogramReport(this.latencyHistogram);
}

代码示例来源：origin: org.apache.hbase/hbase-mapreduce

/**
 * @return Subset of the histograms' calculation.
 */
public String getShortValueSizeReport() {
 return YammerHistogramUtils.getShortHistogramReport(this.valueSizeHistogram);
}