diff --git a/plotting/utils/mergeYCSB.py b/plotting/utils/mergeYCSB.py index 6b96d1a65646cd110696dd7a93e12cfd6820b499..5e13ba10d0252ec6465ba8a7ed7acc24c21b71b8 100644 --- a/plotting/utils/mergeYCSB.py +++ b/plotting/utils/mergeYCSB.py @@ -197,7 +197,35 @@ def mergeOverallData(results, resultFolder, outputFile): # key is already there, sum up value mergedInsertDic[metricName] = (mergedInsertDic[metricName] + float(valueItem))/2 else: - mergedInsertDic[metricName] = float(valueItem) + mergedInsertDic[metricName] = float(valueItem) + if "[INSERT], 95thPercentileLatency(us)" in line: + #extract current ops per second + splittedLine = line.split(",") + valueItem = splittedLine[2] + valueItem = valueItem.strip() + + #extract timestamp + metricName = splittedLine[1] + + if metricName in mergedInsertDic: + # key is already there, sum up value + mergedInsertDic[metricName] = (mergedInsertDic[metricName] + float(valueItem))/2 + else: + mergedInsertDic[metricName] = float(valueItem) + if "[INSERT], 99thPercentileLatency(us)" in line: + #extract current ops per second + splittedLine = line.split(",") + valueItem = splittedLine[2] + valueItem = valueItem.strip() + + #extract timestamp + metricName = splittedLine[1] + + if metricName in mergedInsertDic: + # key is already there, sum up value + mergedInsertDic[metricName] = (mergedInsertDic[metricName] + float(valueItem))/2 + else: + mergedInsertDic[metricName] = float(valueItem) if "[INSERT], MinLatency(us)" in line: #extract current ops per second splittedLine = line.split(",")