in stresso/src/main/java/stresso/trie/Print.java [70:108]
public static Stats getStats(SimpleConfiguration config) throws Exception {
try (FluoClient client = FluoFactory.newClient(config); Snapshot snap = client.newSnapshot()) {
StressoConfig sconf = StressoConfig.retrieve(client);
RowScanner rows = snap.scanner().over(Span.prefix(String.format("%02d:", sconf.stopLevel)))
.fetch(Constants.COUNT_SEEN_COL, Constants.COUNT_WAIT_COL).byRow().build();
long totalSeen = 0;
long totalWait = 0;
int otherNodeSizes = 0;
long nodes = 0;
for (ColumnScanner columns : rows) {
String row = columns.getsRow();
Node node = new Node(row);
if (node.getNodeSize() == sconf.nodeSize) {
for (ColumnValue cv : columns) {
if (cv.getColumn().equals(Constants.COUNT_SEEN_COL)) {
totalSeen += Long.parseLong(cv.getsValue());
} else {
totalWait += Long.parseLong(cv.getsValue());
}
}
nodes++;
} else {
otherNodeSizes++;
}
}
return new Stats(totalWait, totalSeen, nodes, otherNodeSizes != 0);
}
}