diff --git a/source/dnode/vnode/src/tsdb/tsdbFS2.c b/source/dnode/vnode/src/tsdb/tsdbFS2.c
index 30ce2c2256..5db7a89e4a 100644
--- a/source/dnode/vnode/src/tsdb/tsdbFS2.c
+++ b/source/dnode/vnode/src/tsdb/tsdbFS2.c
@@ -678,4 +678,35 @@ int32_t tsdbFSDestroyCopySnapshot(TFileSetArray **fsetArr) {
     fsetArr[0] = NULL;
   }
   return 0;
+}
+
+int32_t tsdbFSCreateRefSnapshot(STFileSystem *fs, TFileSetArray **fsetArr) {
+  int32_t    code = 0;
+  STFileSet *fset, *fset1;
+
+  fsetArr[0] = taosMemoryCalloc(sizeof(*fsetArr[0]));
+  if (fsetArr[0] == NULL) return TSDB_CODE_OUT_OF_MEMORY;
+
+  taosThreadRwlockRdlock(&fs->tsdb->rwLock);
+  TARRAY2_FOREACH(fs->fSetArr, fset) {
+    // TODO: create ref fset of fset1
+
+    code = TARRAY2_APPEND(fsetArr[0], fset1);
+    if (code) break;
+  }
+  taosThreadRwlockUnlock(&fs->tsdb->rwLock);
+
+  if (code) {
+    TARRAY2_DESTROY(fsetArr[0], NULL /* TODO */);
+    fsetArr[0] = NULL;
+  }
+  return code;
+}
+
+int32_t tsdbFSDestroyRefSnapshot(TFileSetArray **fsetArr) {
+  if (fsetArr[0]) {
+    TARRAY2_DESTROY(fsetArr[0], NULL /* TODO */);
+    fsetArr[0] = NULL;
+  }
+  return 0;
 }
\ No newline at end of file
diff --git a/source/dnode/vnode/src/tsdb/tsdbFS2.h b/source/dnode/vnode/src/tsdb/tsdbFS2.h
index e16ca5cee6..074ce7c551 100644
--- a/source/dnode/vnode/src/tsdb/tsdbFS2.h
+++ b/source/dnode/vnode/src/tsdb/tsdbFS2.h
@@ -38,6 +38,8 @@ int32_t tsdbCloseFS(STFileSystem **fs);
 // snapshot
 int32_t tsdbFSCreateCopySnapshot(STFileSystem *fs, TFileSetArray **fsetArr);
 int32_t tsdbFSDestroyCopySnapshot(TFileSetArray **fsetArr);
+int32_t tsdbFSCreateRefSnapshot(STFileSystem *fs, TFileSetArray **fsetArr);
+int32_t tsdbFSDestroyRefSnapshot(TFileSetArray **fsetArr);
 // txn
 int64_t tsdbFSAllocEid(STFileSystem *fs);
 int32_t tsdbFSEditBegin(STFileSystem *fs, const TFileOpArray *opArray, EFEditT etype);