You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@hbase.apache.org by an...@apache.org on 2013/10/16 09:29:48 UTC
svn commit: r1532663 - in
/hbase/trunk/hbase-client/src/main/java/org/apache/hadoop/hbase/client:
Put.java Scan.java
Author: anoopsamjohn
Date: Wed Oct 16 07:29:47 2013
New Revision: 1532663
URL: http://svn.apache.org/r1532663
Log:
HBASE-9761 Put copy constructor should clone the operation attributes also
Modified:
hbase/trunk/hbase-client/src/main/java/org/apache/hadoop/hbase/client/Put.java
hbase/trunk/hbase-client/src/main/java/org/apache/hadoop/hbase/client/Scan.java
Modified: hbase/trunk/hbase-client/src/main/java/org/apache/hadoop/hbase/client/Put.java
URL: http://svn.apache.org/viewvc/hbase/trunk/hbase-client/src/main/java/org/apache/hadoop/hbase/client/Put.java?rev=1532663&r1=1532662&r2=1532663&view=diff
==============================================================================
--- hbase/trunk/hbase-client/src/main/java/org/apache/hadoop/hbase/client/Put.java (original)
+++ hbase/trunk/hbase-client/src/main/java/org/apache/hadoop/hbase/client/Put.java Wed Oct 16 07:29:47 2013
@@ -100,6 +100,9 @@ public class Put extends Mutation implem
this.familyMap.put(entry.getKey(), entry.getValue());
}
this.durability = putToCopy.durability;
+ for (Map.Entry<String, byte[]> entry : putToCopy.getAttributesMap().entrySet()) {
+ this.setAttribute(entry.getKey(), entry.getValue());
+ }
}
/**
Modified: hbase/trunk/hbase-client/src/main/java/org/apache/hadoop/hbase/client/Scan.java
URL: http://svn.apache.org/viewvc/hbase/trunk/hbase-client/src/main/java/org/apache/hadoop/hbase/client/Scan.java?rev=1532663&r1=1532662&r2=1532663&view=diff
==============================================================================
--- hbase/trunk/hbase-client/src/main/java/org/apache/hadoop/hbase/client/Scan.java (original)
+++ hbase/trunk/hbase-client/src/main/java/org/apache/hadoop/hbase/client/Scan.java Wed Oct 16 07:29:47 2013
@@ -222,6 +222,9 @@ public class Scan extends OperationWithA
this.tr = get.getTimeRange();
this.familyMap = get.getFamilyMap();
this.getScan = true;
+ for (Map.Entry<String, byte[]> attr : get.getAttributesMap().entrySet()) {
+ setAttribute(attr.getKey(), attr.getValue());
+ }
}
public boolean isGetScan() {