Added deletion times to ic-sstables

instaclustr · Aug 28, 2018 · 498ef44 · 498ef44
1 parent 11cb5fa
commit 498ef44
Show file tree

Hide file tree

Showing 4 changed files with 12 additions and 0 deletions.
diff --git a/README.md b/README.md
@@ -66,6 +66,8 @@ Print out sstable metadata for a column family. Useful in helping to tune compac
 | Min Timestamp      | Minimum cell timestamp contained in the sstable           |
 | Max Timestamp      | Maximum cell timestamp contained in the sstable           |
 | Duration           | The time span between minimum and maximum cell timestamps |
+| Min Deletion Time  | The minimum deletion time                                 |
+| Max Deletion Time  | The maximum deletion time                                 |
 | Level              | Leveled Tiered Compaction sstable level                   |
 | Keys               | Number of partition keys                                  |
 | Avg Partition Size | Average partition size                                    |

diff --git a/src/com/instaclustr/sstabletools/SSTableMetadata.java b/src/com/instaclustr/sstabletools/SSTableMetadata.java
@@ -51,6 +51,10 @@ public int compare(SSTableMetadata o1, SSTableMetadata o2) {
 
     public long maxTimestamp;
 
+    public int minLocalDeletionTime;
+
+    public int maxLocalDeletionTime;
+
     public long fileTimestamp;
 
     public long diskLength;

diff --git a/src/com/instaclustr/sstabletools/SSTableMetadataCollector.java b/src/com/instaclustr/sstabletools/SSTableMetadataCollector.java
@@ -56,6 +56,8 @@ public static void main(String[] args) {
                     "Max Timestamp",
                     "File Timestamp",
                     "Duration",
+                    "Min Deletion Time",
+                    "Max Deletion Time",
                     "Level",
                     "Keys",
                     "Avg Partition Size",
@@ -89,6 +91,8 @@ public static void main(String[] args) {
                         Util.UTC_DATE_FORMAT.format(new Date(metadata.maxTimestamp / 1000)),
                         Util.UTC_DATE_FORMAT.format(new Date(metadata.fileTimestamp)),
                         Util.humanReadableDateDiff(metadata.minTimestamp / 1000, metadata.maxTimestamp / 1000),
+                        metadata.minLocalDeletionTime != Integer.MAX_VALUE ? Util.UTC_DATE_FORMAT.format(new Date(metadata.minLocalDeletionTime * 1000L)) : "",
+                        metadata.maxLocalDeletionTime != Integer.MAX_VALUE ? Util.UTC_DATE_FORMAT.format(new Date(metadata.maxLocalDeletionTime * 1000L)) : "",
                         Integer.toString(metadata.level),
                         Long.toString(metadata.keys),
                         Util.humanReadableByteCount(metadata.avgRowSize),

diff --git a/src/com/instaclustr/sstabletools/cassandra/CassandraBackend.java b/src/com/instaclustr/sstabletools/cassandra/CassandraBackend.java
@@ -98,6 +98,8 @@ public List<SSTableMetadata> getSSTableMetadata(String ksName, String cfName) {
             }
             tableMetadata.minTimestamp = table.getMinTimestamp();
             tableMetadata.maxTimestamp = table.getMaxTimestamp();
+            tableMetadata.minLocalDeletionTime = table.getSSTableMetadata().minLocalDeletionTime;
+            tableMetadata.maxLocalDeletionTime = table.getSSTableMetadata().maxLocalDeletionTime;
             tableMetadata.diskLength = table.onDiskLength();
             tableMetadata.uncompressedLength = table.uncompressedLength();
             tableMetadata.keys = table.estimatedKeys();