svn commit: r1587417 - /hbase/trunk/hbase-server/src/test/java/org/apache/hadoop/hbase/io/encoding/TestDataBlockEncoders.java

[ramkrishna]

Author: ramkrishna
Date: Tue Apr 15 05:03:27 2014
New Revision: 1587417

URL: http://svn.apache.org/r1587417
Log:
HBASE-10972 - OOBE in prefix key encoding (Ram)

Modified:
    
hbase/trunk/hbase-server/src/test/java/org/apache/hadoop/hbase/io/encoding/TestDataBlockEncoders.java

Modified: 
hbase/trunk/hbase-server/src/test/java/org/apache/hadoop/hbase/io/encoding/TestDataBlockEncoders.java
URL: 
http://svn.apache.org/viewvc/hbase/trunk/hbase-server/src/test/java/org/apache/hadoop/hbase/io/encoding/TestDataBlockEncoders.java?rev=1587417&r1=1587416&r2=1587417&view=diff
==============================================================================
--- 
hbase/trunk/hbase-server/src/test/java/org/apache/hadoop/hbase/io/encoding/TestDataBlockEncoders.java
 (original)
+++ 
hbase/trunk/hbase-server/src/test/java/org/apache/hadoop/hbase/io/encoding/TestDataBlockEncoders.java
 Tue Apr 15 05:03:27 2014
@@ -408,5 +408,27 @@ public class TestDataBlockEncoders {
       assertEquals("Input of two methods is changed", onDataset, dataset);
     }
   }
+  
+  @Test
+  public void testZeroByte() throws IOException {
+    List<KeyValue> kvList = new ArrayList<KeyValue>();
+    byte[] row = Bytes.toBytes("abcd");
+    byte[] family = new byte[] { 'f' };
+    byte[] qualifier0 = new byte[] { 'b' };
+    byte[] qualifier1 = new byte[] { 'c' };
+    byte[] value0 = new byte[] { 'd' };
+    byte[] value1 = new byte[] { 0x00 };
+    if (includesTags) {
+      kvList.add(new KeyValue(row, family, qualifier0, 0, value0, new Tag[] { 
new Tag((byte) 1,
+          "value1") }));
+      kvList.add(new KeyValue(row, family, qualifier1, 0, value1, new Tag[] { 
new Tag((byte) 1,
+          "value1") }));
+    } else {
+      kvList.add(new KeyValue(row, family, qualifier0, 0, Type.Put, value0));
+      kvList.add(new KeyValue(row, family, qualifier1, 0, Type.Put, value1));
+    }
+    testEncodersOnDataset(RedundantKVGenerator.convertKvToByteBuffer(kvList, 
includesMemstoreTS),
+        kvList);
+  }
 
 }