MCPcopy Create free account
hub / github.com/apache/nutch / runQuery

Method runQuery

src/java/org/apache/nutch/api/impl/db/DbReader.java:51–70  ·  view source on GitHub ↗
(DbFilter filter)

Source from the content-addressed store, hash-verified

49 }
50
51 public Iterator<Map<String, Object>> runQuery(DbFilter filter) {
52 String startKey = filter.getStartKey();
53 String endKey = filter.getEndKey();
54
55 if (!filter.isKeysReversed()) {
56 startKey = reverseKey(filter.getStartKey());
57 endKey = reverseKey(filter.getEndKey());
58 }
59
60 Query<String, WebPage> query = store.newQuery();
61 query.setFields(prepareFields(filter.getFields()));
62 if (startKey != null) {
63 query.setStartKey(startKey);
64 if (endKey != null) {
65 query.setEndKey(endKey);
66 }
67 }
68 Result<String, WebPage> result = store.execute(query);
69 return new DbIterator(result, filter.getFields(), filter.getBatchId());
70 }
71
72 private String reverseKey(String key) {
73 if (StringUtils.isEmpty(key)) {

Callers

nothing calls this directly

Calls 10

reverseKeyMethod · 0.95
prepareFieldsMethod · 0.95
getStartKeyMethod · 0.80
getEndKeyMethod · 0.80
isKeysReversedMethod · 0.80
setFieldsMethod · 0.80
setStartKeyMethod · 0.80
setEndKeyMethod · 0.80
getFieldsMethod · 0.65
getBatchIdMethod · 0.45

Tested by

no test coverage detected