in src/main/java/org/apache/accumulo/bsp/AccumuloInputFormat.java [73:84]
public boolean next(Key k, Value v) throws IOException {
if (scannerIterator.hasNext()) {
++numKeysRead;
Entry<Key,Value> entry = scannerIterator.next();
currentKey = entry.getKey();
currentValue = entry.getValue();
k.set(currentKey);
v.set(currentValue.get());
return true;
}
return false;
}