diff --git a/samza-core/src/main/scala/org/apache/samza/storage/ContainerStorageManagerUtil.java b/samza-core/src/main/scala/org/apache/samza/storage/ContainerStorageManagerUtil.java index badd5e71f5..d6aa7bd55d 100644 --- a/samza-core/src/main/scala/org/apache/samza/storage/ContainerStorageManagerUtil.java +++ b/samza-core/src/main/scala/org/apache/samza/storage/ContainerStorageManagerUtil.java @@ -401,18 +401,6 @@ public static Set getSideInputStoreNames( return sideInputStores; } - public static Set getNonSideInputNonInMemoryStores(Map> storageEngineFactories, - Set sideInputStoreNames, Config config) { - Set inMemoryStoreNames = - ContainerStorageManagerUtil.getInMemoryStoreNames(storageEngineFactories, config); - Set nonSideInputStoreNames = - storageEngineFactories.keySet().stream().filter(storeName -> !sideInputStoreNames.contains(storeName)) - .collect(Collectors.toSet()); - Set storeNames = nonSideInputStoreNames.stream() - .filter(s -> !inMemoryStoreNames.contains(s)).collect(Collectors.toSet()); - return storeNames; - } - public static Set getStoreDirPaths(Config config, Map> storageEngineFactories, Map activeTaskChangelogSystemStreams, Set sideInputStoreNames, ContainerModel containerModel, StorageManagerUtil storageManagerUtil, File loggedStoreBaseDirectory,