You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@accumulo.apache.org by vi...@apache.org on 2012/01/11 21:24:01 UTC
svn commit: r1230232 -
/incubator/accumulo/trunk/src/server/src/test/java/org/apache/accumulo/server/tabletserver/InMemoryMapTest.java
Author: vines
Date: Wed Jan 11 20:24:01 2012
New Revision: 1230232
URL: http://svn.apache.org/viewvc?rev=1230232&view=rev
Log:
ACCUMULO-227 - junit test goodness
Modified:
incubator/accumulo/trunk/src/server/src/test/java/org/apache/accumulo/server/tabletserver/InMemoryMapTest.java
Modified: incubator/accumulo/trunk/src/server/src/test/java/org/apache/accumulo/server/tabletserver/InMemoryMapTest.java
URL: http://svn.apache.org/viewvc/incubator/accumulo/trunk/src/server/src/test/java/org/apache/accumulo/server/tabletserver/InMemoryMapTest.java?rev=1230232&r1=1230231&r2=1230232&view=diff
==============================================================================
--- incubator/accumulo/trunk/src/server/src/test/java/org/apache/accumulo/server/tabletserver/InMemoryMapTest.java (original)
+++ incubator/accumulo/trunk/src/server/src/test/java/org/apache/accumulo/server/tabletserver/InMemoryMapTest.java Wed Jan 11 20:24:01 2012
@@ -275,4 +275,18 @@ public class InMemoryMapTest extends Tes
ae(skvi1, "r1", "foo:cq1", 3, "bar1");
}
+
+ public void testDuplicateKey() throws Exception {
+ InMemoryMap imm = new InMemoryMap(false, "/tmp");
+
+ Mutation m = new Mutation(new Text("r1"));
+ m.put(new Text("foo"), new Text("cq"), 3, new Value("v1".getBytes()));
+ m.put(new Text("foo"), new Text("cq"), 3, new Value("v2".getBytes()));
+ imm.mutate(Collections.singletonList(m));
+
+ MemoryIterator skvi1 = imm.skvIterator();
+ skvi1.seek(new Range(), LocalityGroupUtil.EMPTY_CF_SET, false);
+ ae(skvi1, "r1", "foo:cq", 3, "v2");
+ ae(skvi1, "r1", "foo:cq", 3, "v1");
+ }
}