This is an automated email from the ASF dual-hosted git repository.
sarvekshayr pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/ozone.git
The following commit(s) were added to refs/heads/master by this push:
new 9665a209d84 HDDS-14156. Replace ByteArrayCodec with CodecBufferCodec
in FSORepairTool (#9500)
9665a209d84 is described below
commit 9665a209d8430216a9ecc9cf3c81568f3597b673
Author: Sarveksha Yeshavantha Raju
<[email protected]>
AuthorDate: Tue Dec 16 14:16:24 2025 +0530
HDDS-14156. Replace ByteArrayCodec with CodecBufferCodec in FSORepairTool
(#9500)
---
.../org/apache/hadoop/ozone/repair/om/FSORepairTool.java | 16 ++++++++--------
1 file changed, 8 insertions(+), 8 deletions(-)
diff --git
a/hadoop-ozone/tools/src/main/java/org/apache/hadoop/ozone/repair/om/FSORepairTool.java
b/hadoop-ozone/tools/src/main/java/org/apache/hadoop/ozone/repair/om/FSORepairTool.java
index 57b9736b71d..85c7ca356ef 100644
---
a/hadoop-ozone/tools/src/main/java/org/apache/hadoop/ozone/repair/om/FSORepairTool.java
+++
b/hadoop-ozone/tools/src/main/java/org/apache/hadoop/ozone/repair/om/FSORepairTool.java
@@ -30,7 +30,8 @@
import org.apache.hadoop.hdds.conf.ConfigurationSource;
import org.apache.hadoop.hdds.conf.OzoneConfiguration;
import org.apache.hadoop.hdds.utils.db.BatchOperation;
-import org.apache.hadoop.hdds.utils.db.ByteArrayCodec;
+import org.apache.hadoop.hdds.utils.db.CodecBuffer;
+import org.apache.hadoop.hdds.utils.db.CodecBufferCodec;
import org.apache.hadoop.hdds.utils.db.DBStore;
import org.apache.hadoop.hdds.utils.db.DBStoreBuilder;
import org.apache.hadoop.hdds.utils.db.StringCodec;
@@ -86,7 +87,6 @@ public class FSORepairTool extends RepairTool {
private static final Logger LOG =
LoggerFactory.getLogger(FSORepairTool.class);
private static final String REACHABLE_TABLE = "reachable";
private static final String PENDING_TO_DELETE_TABLE = "pendingToDelete";
- private static final byte[] EMPTY_BYTE_ARRAY = {};
@CommandLine.Option(names = {"--db"},
required = true,
@@ -133,8 +133,8 @@ private class Impl {
private final Table<String, RepeatedOmKeyInfo> deletedTable;
private final Table<String, SnapshotInfo> snapshotInfoTable;
private DBStore tempDB;
- private Table<String, byte[]> reachableTable;
- private Table<String, byte[]> pendingToDeleteTable;
+ private Table<String, CodecBuffer> reachableTable;
+ private Table<String, CodecBuffer> pendingToDeleteTable;
private final ReportStatistics reachableStats;
private final ReportStatistics pendingToDeleteStats;
private final ReportStatistics orphanedStats;
@@ -553,7 +553,7 @@ private Collection<String>
getChildDirectoriesAndMarkAsPendingToDelete(String di
private void addReachableEntry(OmVolumeArgs volume, OmBucketInfo bucket,
WithObjectID object) throws IOException {
String reachableKey = buildReachableKey(volume, bucket, object);
// No value is needed for this table.
- reachableTable.put(reachableKey, EMPTY_BYTE_ARRAY);
+ reachableTable.put(reachableKey, CodecBuffer.getEmptyBuffer());
}
/**
@@ -562,7 +562,7 @@ private void addReachableEntry(OmVolumeArgs volume,
OmBucketInfo bucket, WithObj
*/
private void addPendingToDeleteEntry(String originalKey) throws
IOException {
// No value is needed for this table.
- pendingToDeleteTable.put(originalKey, EMPTY_BYTE_ARRAY);
+ pendingToDeleteTable.put(originalKey, CodecBuffer.getEmptyBuffer());
}
/**
@@ -598,8 +598,8 @@ private void openTempDB() throws IOException {
.addTable(REACHABLE_TABLE)
.addTable(PENDING_TO_DELETE_TABLE)
.build();
- reachableTable = tempDB.getTable(REACHABLE_TABLE, StringCodec.get(),
ByteArrayCodec.get());
- pendingToDeleteTable = tempDB.getTable(PENDING_TO_DELETE_TABLE,
StringCodec.get(), ByteArrayCodec.get());
+ reachableTable = tempDB.getTable(REACHABLE_TABLE, StringCodec.get(),
CodecBufferCodec.get(true));
+ pendingToDeleteTable = tempDB.getTable(PENDING_TO_DELETE_TABLE,
StringCodec.get(), CodecBufferCodec.get(true));
}
private void closeTempDB() throws IOException {
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
