I would like to get all the versions of a row for a map-reduce task.
Given the details below, I'm afraid I was just looking too hard and
there's a simpler solution.
Here is what I found out:
1) Looking at TableInputFormat at the internal class
TableInputFormat.TableRecordReader there is a call to
m_table.obtainScanner(m_cols, startRow);
2) I thought that changing the HTable.ClientScanner will do the work.
Specifically changing the next() method.
However, in Hbase 1.2 the code is as follows:
do {
values = server.next(scannerId);
} while (values != null && values.size() == 0 &&
nextScanner());
3) Next thing, I was looking at the HResgionServer which seems to be
dependent on the HRegion class.
4) Finally, will changing the internal HRegion.HScanner() is the
solution to this daunting problem or is there something easier ?
Comments and suggestions are very welcome
-Yair
