public static Stats getStats()

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);
    }

  }