Skip to content

Commit

Permalink
Remove ununsed method
Browse files Browse the repository at this point in the history
  • Loading branch information
shekhars-li committed Apr 4, 2024
1 parent 0dab28b commit be7553d
Showing 1 changed file with 0 additions and 12 deletions.
Original file line number Diff line number Diff line change
Expand Up @@ -401,18 +401,6 @@ public static Set<String> getSideInputStoreNames(
return sideInputStores;
}

public static Set<String> getNonSideInputNonInMemoryStores(Map<String, StorageEngineFactory<Object, Object>> storageEngineFactories,
Set<String> sideInputStoreNames, Config config) {
Set<String> inMemoryStoreNames =
ContainerStorageManagerUtil.getInMemoryStoreNames(storageEngineFactories, config);
Set<String> nonSideInputStoreNames =
storageEngineFactories.keySet().stream().filter(storeName -> !sideInputStoreNames.contains(storeName))
.collect(Collectors.toSet());
Set<String> storeNames = nonSideInputStoreNames.stream()
.filter(s -> !inMemoryStoreNames.contains(s)).collect(Collectors.toSet());
return storeNames;
}

public static Set<Path> getStoreDirPaths(Config config, Map<String, StorageEngineFactory<Object, Object>> storageEngineFactories,
Map<String, SystemStream> activeTaskChangelogSystemStreams, Set<String> sideInputStoreNames,
ContainerModel containerModel, StorageManagerUtil storageManagerUtil, File loggedStoreBaseDirectory,
Expand Down

0 comments on commit be7553d

Please sign in to comment.