Index: src/java/org/apache/hadoop/hbase/client/HTable.java =================================================================== --- src/java/org/apache/hadoop/hbase/client/HTable.java (revision 707982) +++ src/java/org/apache/hadoop/hbase/client/HTable.java (working copy) @@ -1338,6 +1338,28 @@ return null; } + /** + * + * @param nbRows number of rows to return + * @return rows of RowResults + * @throws IOException + */ + public RowResult[] next(int nbRows) throws IOException { + // Collect values to be returned here + ArrayList resultSets = new ArrayList(); + + for(int i = 0; i< nbRows; i++) { + RowResult next = next(); + if (next != null) { + resultSets.add(next); + } else { + break; + } + } + + return resultSets.toArray(new RowResult[resultSets.size()]); + } + public void close() { if (callable != null) { callable.setClose();