HBASE-17731 Fractional latency reporting in MultiThreadedAction
Project: http://git-wip-us.apache.org/repos/asf/hbase/repo Commit: http://git-wip-us.apache.org/repos/asf/hbase/commit/286ade81 Tree: http://git-wip-us.apache.org/repos/asf/hbase/tree/286ade81 Diff: http://git-wip-us.apache.org/repos/asf/hbase/diff/286ade81 Branch: refs/heads/branch-1.3 Commit: 286ade8155e5c198feef83bbd5fcc4f00a3d7796 Parents: 109219d Author: Andrew Purtell <apurt...@apache.org> Authored: Thu Mar 9 16:54:23 2017 -0800 Committer: Andrew Purtell <apurt...@apache.org> Committed: Wed Dec 12 18:08:16 2018 -0800 ---------------------------------------------------------------------- .../org/apache/hadoop/hbase/util/MultiThreadedAction.java | 8 +++++--- 1 file changed, 5 insertions(+), 3 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/hbase/blob/286ade81/hbase-server/src/test/java/org/apache/hadoop/hbase/util/MultiThreadedAction.java ---------------------------------------------------------------------- diff --git a/hbase-server/src/test/java/org/apache/hadoop/hbase/util/MultiThreadedAction.java b/hbase-server/src/test/java/org/apache/hadoop/hbase/util/MultiThreadedAction.java index 91b6d3b..0d25a68 100644 --- a/hbase-server/src/test/java/org/apache/hadoop/hbase/util/MultiThreadedAction.java +++ b/hbase-server/src/test/java/org/apache/hadoop/hbase/util/MultiThreadedAction.java @@ -218,11 +218,13 @@ public abstract class MultiThreadedAction { + ", time=" + formatTime(time) + ((numKeys > 0 && time > 0) ? (" Overall: [" + "keys/s= " - + numKeys * 1000 / time + ", latency=" + totalOpTime - / numKeys + " ms]") : "") + + numKeys * 1000 / time + ", latency=" + + String.format("%.2f", (double)totalOpTime / (double)numKeys) + + " ms]") : "") + ((numKeysDelta > 0) ? (" Current: [" + "keys/s=" + numKeysDelta * 1000 / REPORTING_INTERVAL_MS + ", latency=" - + totalOpTimeDelta / numKeysDelta + " ms]") : "") + + String.format("%.2f", (double)totalOpTimeDelta / (double)numKeysDelta) + + " ms]") : "") + progressInfo()); if (streamingCounters) {
