Added deleted rows to summary

burmanm · Aug 8, 2018 · 4c8c0ca · 4c8c0ca
1 parent a026a59
commit 4c8c0ca
Show file tree

Hide file tree

Showing 2 changed files with 4 additions and 0 deletions.
diff --git a/README.md b/README.md
@@ -140,6 +140,7 @@ Summary: Summary statistics about partitions
 |----------------------------------------------|----------------------------------------------------------|
 | Count (Size)                                 | Number of partition keys on this node                    |
 | Rows (Size)                                  | Number of clustering rows                                |
+| (deleted)                                    | Number of clustering row deletions                       |
 | Total (Size)                                 | Total uncompressed size of all partitions on this node   |
 | Total (SSTable)                              | Number of sstables on this node                          |
 | Minimum (Size)                               | Minimum uncompressed partition size                      |

diff --git a/src/com/instaclustr/sstabletools/ColumnFamilyStatisticsCollector.java b/src/com/instaclustr/sstabletools/ColumnFamilyStatisticsCollector.java
@@ -120,6 +120,7 @@ public static void main(String[] args) {
             long maxPartitionSize = 0;
             long partitionCount = 0;
             long rowCount = 0;
+            long rowDeleteCount = 0;
             long totalPartitionSize = 0;
             int minTables = Integer.MAX_VALUE;
             int maxTables = 0;
@@ -173,6 +174,7 @@ public static void main(String[] args) {
                 maxTables = Math.max(maxTables, pStats.tableCount);
                 totalTables += pStats.tableCount;
                 rowCount += pStats.rowCount;
+                rowDeleteCount += pStats.rowDeleteCount;
                 partitionCount++;
             }
 
@@ -183,6 +185,7 @@ public static void main(String[] args) {
             tb.setHeader("", "Size", "SSTable");
             tb.addRow("Count", Long.toString(partitionCount), "");
             tb.addRow("Rows", Long.toString(rowCount), "");
+            tb.addRow("(deleted)", Long.toString(rowDeleteCount), "");
             tb.addRow("Total", Util.humanReadableByteCount(totalPartitionSize), Integer.toString(sstableReaders.size()));
             tb.addRow("Minimum", Util.humanReadableByteCount(minPartitionSize), Integer.toString(minTables));
             tb.addRow("Maximum", Util.humanReadableByteCount(maxPartitionSize), Integer.toString(maxTables));