in src/main/java/com/netflix/bdp/s3mper/metastore/impl/BigTableMetastore.java [74:93]
public List<FileInfo> list(List<Path> parents) throws Exception {
ImmutableList.Builder<FileInfo> result = ImmutableList.builder();
// Now scan across all columns in row.
for (Path parent: parents) {
Result row = new RetryTask<Result>(
new GetTask(parent), retryCount, timeout).call();
NavigableMap<byte[], byte[]> data = row.getFamilyMap(COLUMN_FAMILY_NAME);
if (data != null) {
for (Map.Entry<byte[], byte[]> entry : data.entrySet()) {
String name = Bytes.toString(entry.getKey());
String jsonBlob = Bytes.toString(entry.getValue());
Map mmm = mapper.readValue(jsonBlob, HashMap.class);
result.add(new FileInfo(new Path(parent, name), false, (Boolean) mmm.get("isDirectory")));
}
}
}
return result.build();
}