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 2009/03/06 07:13:18 UTC
svn commit: r750777 - in /hadoop/hbase/trunk: CHANGES.txt
src/java/org/apache/hadoop/hbase/io/BatchUpdate.java
Author: stack
Date: Fri Mar 6 06:13:17 2009
New Revision: 750777
URL: http://svn.apache.org/viewvc?rev=750777&view=rev
Log:
HBASE-1231 Today, going from a RowResult to a BatchUpdate reqiures some data processing even though they are pretty much the same thing.
Modified:
hadoop/hbase/trunk/CHANGES.txt
hadoop/hbase/trunk/src/java/org/apache/hadoop/hbase/io/BatchUpdate.java
Modified: hadoop/hbase/trunk/CHANGES.txt
URL: http://svn.apache.org/viewvc/hadoop/hbase/trunk/CHANGES.txt?rev=750777&r1=750776&r2=750777&view=diff
==============================================================================
--- hadoop/hbase/trunk/CHANGES.txt (original)
+++ hadoop/hbase/trunk/CHANGES.txt Fri Mar 6 06:13:17 2009
@@ -73,6 +73,9 @@
HeapSize (Erik Holstad via Stack)
HBASE-1230 Document installation of HBase on Windows
HBASE-1241 HBase additions to ZooKeeper part 1 (Nitay Joffe via JD)
+ HBASE-1231 Today, going from a RowResult to a BatchUpdate reqiures some
+ data processing even though they are pretty much the same thing
+ (Erik Holstad via Stack)
Release 0.19.0 - 01/21/2009
INCOMPATIBLE CHANGES
Modified: hadoop/hbase/trunk/src/java/org/apache/hadoop/hbase/io/BatchUpdate.java
URL: http://svn.apache.org/viewvc/hadoop/hbase/trunk/src/java/org/apache/hadoop/hbase/io/BatchUpdate.java?rev=750777&r1=750776&r2=750777&view=diff
==============================================================================
--- hadoop/hbase/trunk/src/java/org/apache/hadoop/hbase/io/BatchUpdate.java (original)
+++ hadoop/hbase/trunk/src/java/org/apache/hadoop/hbase/io/BatchUpdate.java Fri Mar 6 06:13:17 2009
@@ -27,10 +27,12 @@
import java.util.ArrayList;
import java.util.Arrays;
import java.util.Iterator;
+import java.util.Map;
import org.apache.commons.logging.Log;
import org.apache.commons.logging.LogFactory;
import org.apache.hadoop.hbase.HConstants;
+import org.apache.hadoop.hbase.io.RowResult;
import org.apache.hadoop.hbase.util.Bytes;
import org.apache.hadoop.io.WritableComparable;
@@ -129,6 +131,18 @@
this.operations = new ArrayList<BatchOperation>();
this.size = (row == null)? 0: row.length;
}
+
+ /**
+ * Create a batch operation.
+ * @param rr the RowResult
+ */
+ public BatchUpdate(final RowResult rr) {
+ this(rr.getRow());
+ for(Map.Entry<byte[], Cell> entry : rr.entrySet()){
+ this.put(entry.getKey(), entry.getValue().getValue());
+ }
+ }
+
/**
* Get the row lock associated with this update
* @return the row lock