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:11:09 UTC
svn commit: r750776 - in /hadoop/hbase/branches/0.19: CHANGES.txt
src/java/org/apache/hadoop/hbase/io/BatchUpdate.java
Author: stack
Date: Fri Mar 6 06:11:09 2009
New Revision: 750776
URL: http://svn.apache.org/viewvc?rev=750776&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/branches/0.19/CHANGES.txt
hadoop/hbase/branches/0.19/src/java/org/apache/hadoop/hbase/io/BatchUpdate.java
Modified: hadoop/hbase/branches/0.19/CHANGES.txt
URL: http://svn.apache.org/viewvc/hadoop/hbase/branches/0.19/CHANGES.txt?rev=750776&r1=750775&r2=750776&view=diff
==============================================================================
--- hadoop/hbase/branches/0.19/CHANGES.txt (original)
+++ hadoop/hbase/branches/0.19/CHANGES.txt Fri Mar 6 06:11:09 2009
@@ -30,6 +30,9 @@
HBASE-1187 After disabling/enabling a table, the regions seems to
be assigned to only 1-2 region servers
HBASE-1151 Don't ship hbase 0.19.1 till hadoop 0.19.1
+ 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
INCOMPATIBLE CHANGES
Modified: hadoop/hbase/branches/0.19/src/java/org/apache/hadoop/hbase/io/BatchUpdate.java
URL: http://svn.apache.org/viewvc/hadoop/hbase/branches/0.19/src/java/org/apache/hadoop/hbase/io/BatchUpdate.java?rev=750776&r1=750775&r2=750776&view=diff
==============================================================================
--- hadoop/hbase/branches/0.19/src/java/org/apache/hadoop/hbase/io/BatchUpdate.java (original)
+++ hadoop/hbase/branches/0.19/src/java/org/apache/hadoop/hbase/io/BatchUpdate.java Fri Mar 6 06:11:09 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