svn commit: r1589733 - /hbase/trunk/hbase-server/src/test/java/org/apache/hadoop/hbase/PerformanceEvaluation.java

[nk...@apache.org]

Author: nkeywal
Date: Thu Apr 24 14:06:17 2014
New Revision: 1589733

URL: http://svn.apache.org/r1589733
Log:
HBASE-11055 Extends the sampling size

Modified:
    hbase/trunk/hbase-server/src/test/java/org/apache/hadoop/hbase/PerformanceEvaluation.java

Modified: hbase/trunk/hbase-server/src/test/java/org/apache/hadoop/hbase/PerformanceEvaluation.java
URL: http://svn.apache.org/viewvc/hbase/trunk/hbase-server/src/test/java/org/apache/hadoop/hbase/PerformanceEvaluation.java?rev=1589733&r1=1589732&r2=1589733&view=diff
==============================================================================
--- hbase/trunk/hbase-server/src/test/java/org/apache/hadoop/hbase/PerformanceEvaluation.java (original)
+++ hbase/trunk/hbase-server/src/test/java/org/apache/hadoop/hbase/PerformanceEvaluation.java Thu Apr 24 14:06:17 2014
@@ -84,6 +84,8 @@ import org.codehaus.jackson.map.ObjectMa
 import com.google.common.util.concurrent.ThreadFactoryBuilder;
 import com.yammer.metrics.core.Histogram;
 import com.yammer.metrics.core.MetricsRegistry;
+import com.yammer.metrics.stats.UniformSample;
+import com.yammer.metrics.stats.Snapshot;
 
 /**
  * Script used evaluating HBase performance and scalability.  Runs a HBase
@@ -581,8 +583,15 @@ public class PerformanceEvaluation exten
       this.table.setAutoFlush(opts.autoFlush, true);
       String metricName =
           testName + "-Client-" + Thread.currentThread().getName() + "-testRowTime";
-      latency =
-          metricsRegistry.newHistogram(PerformanceEvaluation.class, metricName);
+
+      try {
+        Constructor ctor = Histogram.class.getDeclaredConstructor(com.yammer.metrics.stats.Sample.class);
+        ctor.setAccessible(true);
+        latency = (Histogram) ctor.newInstance(new UniformSample(1024 * 500));
+      } catch (Exception e) {
+        throw new RuntimeException(e);
+      }
+
     }
 
     void testTakedown() throws IOException {
@@ -634,15 +643,16 @@ public class PerformanceEvaluation exten
     private void reportLatency() throws IOException {
       status.setStatus(testName + " latency log (microseconds), on " +
           latency.count() + " measures");
+      Snapshot sn = latency.getSnapshot();
       status.setStatus(testName + " Min      = " + latency.min());
       status.setStatus(testName + " Avg      = " + latency.mean());
       status.setStatus(testName + " StdDev   = " + latency.stdDev());
-      status.setStatus(testName + " 50th     = " + latency.getSnapshot().getMedian());
-      status.setStatus(testName + " 95th     = " + latency.getSnapshot().get95thPercentile());
-      status.setStatus(testName + " 99th     = " + latency.getSnapshot().get99thPercentile());
-      status.setStatus(testName + " 99.9th   = " + latency.getSnapshot().get999thPercentile());
-      status.setStatus(testName + " 99.99th  = " + latency.getSnapshot().getValue(0.9999));
-      status.setStatus(testName + " 99.9999th= " + latency.getSnapshot().getValue(0.99999));
+      status.setStatus(testName + " 50th     = " + sn.getMedian());
+      status.setStatus(testName + " 95th     = " + sn.get95thPercentile());
+      status.setStatus(testName + " 99th     = " + sn.get99thPercentile());
+      status.setStatus(testName + " 99.9th   = " + sn.get999thPercentile());
+      status.setStatus(testName + " 99.99th  = " + sn.getValue(0.9999));
+      status.setStatus(testName + " 99.999th = " + sn.getValue(0.99999));
       status.setStatus(testName + " Max      = " + latency.max());
     }