diff --git a/hadoop-hdds/rocksdb-checkpoint-differ/src/main/java/org/apache/ozone/rocksdiff/CompactionNode.java b/hadoop-hdds/rocksdb-checkpoint-differ/src/main/java/org/apache/ozone/rocksdiff/CompactionNode.java index 91c7272d239a..7dddb6a3b77b 100644 --- a/hadoop-hdds/rocksdb-checkpoint-differ/src/main/java/org/apache/ozone/rocksdiff/CompactionNode.java +++ b/hadoop-hdds/rocksdb-checkpoint-differ/src/main/java/org/apache/ozone/rocksdiff/CompactionNode.java @@ -32,6 +32,11 @@ public class CompactionNode { private final String endKey; private final String columnFamily; + /** + * CompactionNode constructor. + * @param file SST file (filename without extension) + * @param seqNum Snapshot generation (sequence number) + */ public CompactionNode(String file, long seqNum, String startKey, String endKey, String columnFamily) { fileName = file; totalNumberOfKeys = 0L; diff --git a/hadoop-hdds/rocksdb-checkpoint-differ/src/main/java/org/apache/ozone/rocksdiff/RocksDBCheckpointDiffer.java b/hadoop-hdds/rocksdb-checkpoint-differ/src/main/java/org/apache/ozone/rocksdiff/RocksDBCheckpointDiffer.java index 3dae2bc6981e..8f288ddc4587 100644 --- a/hadoop-hdds/rocksdb-checkpoint-differ/src/main/java/org/apache/ozone/rocksdiff/RocksDBCheckpointDiffer.java +++ b/hadoop-hdds/rocksdb-checkpoint-differ/src/main/java/org/apache/ozone/rocksdiff/RocksDBCheckpointDiffer.java @@ -1205,8 +1205,8 @@ public boolean shouldRun() { } @VisibleForTesting - public ConcurrentHashMap getCompactionNodeMap() { - return (ConcurrentHashMap) compactionDag.getCompactionMap(); + public ConcurrentMap getCompactionNodeMap() { + return compactionDag.getCompactionMap(); } @VisibleForTesting diff --git a/hadoop-hdds/rocksdb-checkpoint-differ/src/test/java/org/apache/ozone/rocksdiff/TestRocksDBCheckpointDiffer.java b/hadoop-hdds/rocksdb-checkpoint-differ/src/test/java/org/apache/ozone/rocksdiff/TestRocksDBCheckpointDiffer.java index 6c6ba6f1ac19..b6b05a02cc02 100644 --- a/hadoop-hdds/rocksdb-checkpoint-differ/src/test/java/org/apache/ozone/rocksdiff/TestRocksDBCheckpointDiffer.java +++ b/hadoop-hdds/rocksdb-checkpoint-differ/src/test/java/org/apache/ozone/rocksdiff/TestRocksDBCheckpointDiffer.java @@ -62,7 +62,6 @@ import java.util.Optional; import java.util.Set; import java.util.UUID; -import java.util.concurrent.ConcurrentHashMap; import java.util.concurrent.ConcurrentMap; import java.util.concurrent.ExecutionException; import java.util.concurrent.ExecutorService; @@ -1146,7 +1145,7 @@ private void traverseGraph( } private void printMutableGraphFromAGivenNode( - ConcurrentHashMap compactionNodeMap, + ConcurrentMap compactionNodeMap, String fileName, int sstLevel, MutableGraph mutableGraph) {