in webindex/modules/core/src/main/java/webindex/core/IndexClient.java [72:98]
public TopResults getTopResults(String next, int pageNum) {
TopResults results = new TopResults();
results.setPageNum(pageNum);
try {
Scanner scanner = conn.createScanner(accumuloIndexTable, Authorizations.EMPTY);
Pager pager = Pager.build(scanner, Range.prefix("t:"), PAGE_SIZE, entry -> {
String row = entry.getKey().getRow().toString();
if (entry.isNext()) {
results.setNext(row);
} else {
String url = URL.fromUri(row.split(":", 3)[2]).toString();
Long num = Long.parseLong(entry.getValue().toString());
results.addResult(url, num);
}
});
if (next.isEmpty()) {
pager.read(pageNum);
} else {
pager.read(new Key(next));
}
} catch (TableNotFoundException e) {
log.error("Table {} not found", accumuloIndexTable);
}
return results;
}