@VisibleForTesting
  protected BlobStoreUtil createBlobStoreUtil(BlobStoreManager blobStoreManager, ExecutorService executor,
      BlobStoreConfig blobStoreConfig, BlobStoreRestoreManagerMetrics metrics) {
    return new BlobStoreUtil(blobStoreManager, executor, blobStoreConfig, null, metrics);
  }
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