in webindex/modules/core/src/main/java/webindex/core/IndexClient.java [104:139]
public Page getPage(String rawUrl) {
Page page = null;
Long incount = (long) 0;
URL url;
try {
url = URL.from(rawUrl);
} catch (Exception e) {
log.error("Failed to parse URL {}", rawUrl);
return null;
}
try {
Scanner scanner = conn.createScanner(accumuloIndexTable, Authorizations.EMPTY);
scanner.setRange(Range.exact("p:" + url.toUri(), Constants.PAGE));
for (Map.Entry<Key, Value> entry : scanner) {
switch (entry.getKey().getColumnQualifier().toString()) {
case Constants.INCOUNT:
incount = getLongValue(entry);
break;
case Constants.CUR:
page = gson.fromJson(entry.getValue().toString(), Page.class);
break;
default:
log.error("Unknown page stat {}", entry.getKey().getColumnQualifier());
}
}
} catch (TableNotFoundException e) {
e.printStackTrace();
}
if (page == null) {
page = new Page(url.toUri());
}
page.setNumInbound(incount);
return page;
}