private void deleteCheckpointFromBlobStore(DirIndex dirIndex) {
    for (FileIndex file: dirIndex.getFilesPresent()) {
      List<FileBlob> blobs = file.getBlobs();
      for (FileBlob blob: blobs) {
        String blobPath = blob.getBlobId();
        try {
          LOG.debug("Deleting blob: {}", blobPath);
          Files.move(Paths.get(blobPath), Paths.get(blobPath + "-DELETED")); // Delete the file
        } catch (IOException e) {
          throw new RuntimeException("Failed to delete file: " + blobPath, e);
        }
      }
    }
    for (DirIndex subdir: dirIndex.getSubDirsPresent()) {
      deleteCheckpointFromBlobStore(subdir);
    }
  }
Helper function to recursively delete all files from local blob store
@param dirIndex
samza-test/src/test/java/org/apache/samza/storage/kv/BlobStoreStateBackendIntegrationTest.java