private static void deleteCheckpointDirs(TaskName taskName, String storeName, File loggedBaseDir, StorageManagerUtil storageManagerUtil) {
    try {
      List<File> checkpointDirs = storageManagerUtil.getTaskStoreCheckpointDirs(
          loggedBaseDir, storeName, taskName, TaskMode.Active);
      for (File checkpointDir: checkpointDirs) {
        LOG.debug("Deleting local store checkpoint directory: {} before restore.", checkpointDir);
        if (checkpointDir.exists() && checkpointDir.isDirectory()) {
          PathUtils.deleteDirectory(checkpointDir.toPath());
        }
      }
    } catch (Exception e) {
      throw new SamzaException(
          String.format("Error deleting checkpoint directory for task: %s store: %s.",
              taskName, storeName), e);
    }
  }
Starts the restore for the store, enqueuing all restore-completion futures into {@param restoreFutures}.
samza-core/src/main/java/org/apache/samza/storage/blobstore/BlobStoreRestoreManager.java