Refactor some code in RocksDBStdSessions

Change-Id: I0561be1a71322644465e745ded9ca1636bff078a
apache · Mar 26, 2021 · 699d03b · 699d03b
1 parent 060f190
commit 699d03b
Show file tree

Hide file tree

Showing 4 changed files with 201 additions and 191 deletions.
diff --git a/...raph-rocksdb/src/main/java/com/baidu/hugegraph/backend/store/rocksdb/RocksDBSessions.java b/...raph-rocksdb/src/main/java/com/baidu/hugegraph/backend/store/rocksdb/RocksDBSessions.java
@@ -19,13 +19,13 @@
 
 package com.baidu.hugegraph.backend.store.rocksdb;
 
-import java.nio.file.Path;
 import java.util.List;
 import java.util.Set;
 
 import org.apache.commons.lang3.tuple.Pair;
 import org.rocksdb.RocksDBException;
 
+import com.alipay.sofa.jraft.storage.snapshot.remote.Session;
 import com.baidu.hugegraph.backend.store.BackendEntry.BackendColumnIterator;
 import com.baidu.hugegraph.backend.store.BackendSession.AbstractBackendSession;
 import com.baidu.hugegraph.backend.store.BackendSessionPool;
@@ -52,10 +52,10 @@ public abstract RocksDBSessions copy(HugeConfig config,
 
     public abstract void resumeSnapshot(String snapshotPath);
 
-    public abstract Path buildSnapshotPath(Path originDataPath,
-                                           String snapshotPrefix,
-                                           boolean deleteSnapshot)
-                                           throws RocksDBException;
+    public abstract String buildSnapshotPath(String snapshotPrefix);
+
+    public abstract String hardLinkSnapshot(String snapshotPath)
+                                            throws RocksDBException;
 
     public abstract void reloadRocksDB() throws RocksDBException;