You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@hbase.apache.org by st...@apache.org on 2008/10/28 06:03:14 UTC
svn commit: r708435 - in /hadoop/hbase/trunk: CHANGES.txt
src/java/org/apache/hadoop/hbase/client/HTable.java
Author: stack
Date: Mon Oct 27 22:03:13 2008
New Revision: 708435
URL: http://svn.apache.org/viewvc?rev=708435&view=rev
Log:
HBASE-959 Be able to get multiple RowResult at one time from client side
Modified:
hadoop/hbase/trunk/CHANGES.txt
hadoop/hbase/trunk/src/java/org/apache/hadoop/hbase/client/HTable.java
Modified: hadoop/hbase/trunk/CHANGES.txt
URL: http://svn.apache.org/viewvc/hadoop/hbase/trunk/CHANGES.txt?rev=708435&r1=708434&r2=708435&view=diff
==============================================================================
--- hadoop/hbase/trunk/CHANGES.txt (original)
+++ hadoop/hbase/trunk/CHANGES.txt Mon Oct 27 22:03:13 2008
@@ -74,6 +74,8 @@
HBASE-940 Make the TableOutputFormat batching-aware
HBASE-967 [Optimization] Cache cell maximum length (HCD.getMaxValueLength);
its used checking batch size
+ HBASE-959 Be able to get multiple RowResult at one time from client side
+ (Sishen Freecity via Stack)
NEW FEATURES
HBASE-875 Use MurmurHash instead of JenkinsHash [in bloomfilters]
Modified: hadoop/hbase/trunk/src/java/org/apache/hadoop/hbase/client/HTable.java
URL: http://svn.apache.org/viewvc/hadoop/hbase/trunk/src/java/org/apache/hadoop/hbase/client/HTable.java?rev=708435&r1=708434&r2=708435&view=diff
==============================================================================
--- hadoop/hbase/trunk/src/java/org/apache/hadoop/hbase/client/HTable.java (original)
+++ hadoop/hbase/trunk/src/java/org/apache/hadoop/hbase/client/HTable.java Mon Oct 27 22:03:13 2008
@@ -1338,6 +1338,25 @@
return null;
}
+ /**
+ * @param nbRows number of rows to return
+ * @return Between zero and <param>nbRows</param> RowResults
+ * @throws IOException
+ */
+ public RowResult[] next(int nbRows) throws IOException {
+ // Collect values to be returned here
+ ArrayList<RowResult> resultSets = new ArrayList<RowResult>(nbRows);
+ 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();