in src/main/java/com/netflix/bdp/s3mper/metastore/impl/BigTableMetastore.java [96:112]
public void add(List<FileInfo> paths) throws Exception {
Map<Path, List<FileInfo>> data = new HashMap<Path, List<FileInfo>>();
for(FileInfo path: paths) {
Path parent = path.getPath().getParent();
if (!data.containsKey(parent)) {
data.put(parent, new ArrayList<FileInfo>());
}
data.get(parent).add(path);
}
for (Map.Entry<Path, List<FileInfo>> entry : data.entrySet()) {
new RetryTask(
new AddTask(
entry.getKey(),
entry.getValue()),
retryCount, timeout).call();
}
}