private static void clearLoggedStores(File loggedStoreBaseDir) {
    final FileUtil fileUtil = new FileUtil();
    final File[] storeDirs = loggedStoreBaseDir.listFiles();
    if (storeDirs == null || storeDirs.length == 0) {
      LOG.info("No stores to delete");
      return;
    }
    for (File storeDir: storeDirs) {
      LOG.info("Clearing store dir {} from logged stores.", storeDir);
      fileUtil.rm(storeDir);
    }
  }
Starts all the task stores.
Returns the latest checkpoint for each task. This checkpoint may be different from the lastCheckpoint returned by
checkpoint manager in case of a BlobStoreRestoreManager.
samza-core/src/main/scala/org/apache/samza/storage/ContainerStorageManager.java