HBASE-17731 Fractional latency reporting in MultiThreadedAction

This commit is contained in:
Andrew Purtell 2017-03-09 16:54:23 -08:00
parent 26928ff912
commit 7da0feea8d
1 changed files with 5 additions and 3 deletions

View File

@ -215,11 +215,13 @@ public abstract class MultiThreadedAction {
+ ", time=" + ", time="
+ formatTime(time) + formatTime(time)
+ ((numKeys > 0 && time > 0) ? (" Overall: [" + "keys/s= " + ((numKeys > 0 && time > 0) ? (" Overall: [" + "keys/s= "
+ numKeys * 1000 / time + ", latency=" + totalOpTime + numKeys * 1000 / time + ", latency="
/ numKeys + " ms]") : "") + String.format("%.2f", (double)totalOpTime / (double)numKeys)
+ " ms]") : "")
+ ((numKeysDelta > 0) ? (" Current: [" + "keys/s=" + ((numKeysDelta > 0) ? (" Current: [" + "keys/s="
+ numKeysDelta * 1000 / REPORTING_INTERVAL_MS + ", latency=" + numKeysDelta * 1000 / REPORTING_INTERVAL_MS + ", latency="
+ totalOpTimeDelta / numKeysDelta + " ms]") : "") + String.format("%.2f", (double)totalOpTimeDelta / (double)numKeysDelta)
+ " ms]") : "")
+ progressInfo()); + progressInfo());
if (streamingCounters) { if (streamingCounters) {