public CompletableFuture<Void> restore(boolean restoreDeleted) {
    return restoreStores(jobName, jobId, taskModel.getTaskName(), storesToRestore, prevStoreSnapshotIndexes,
        loggedBaseDir, storageConfig, metrics, storageManagerUtil, blobStoreUtil, dirDiffUtil, executor, restoreDeleted,
        blobStoreConfig.shouldCompareFileOwnersOnRestore());
  }
Restore state from checkpoints and state snapshots.
@param restoreDeleted This flag forces the restore to always download the state from blob store with the get deleted
                      flag enabled.
samza-core/src/main/java/org/apache/samza/storage/blobstore/BlobStoreRestoreManager.java