You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@accumulo.apache.org by kt...@apache.org on 2012/01/04 20:16:25 UTC
svn commit: r1227269 - in /incubator/accumulo/branches/1.4/src/core/src:
main/java/org/apache/accumulo/core/client/mock/MockTable.java
test/java/org/apache/accumulo/core/client/mock/MockConnectorTest.java
Author: kturner
Date: Wed Jan 4 19:16:25 2012
New Revision: 1227269
URL: http://svn.apache.org/viewvc?rev=1227269&view=rev
Log:
ACCUMULO-218 made mock accumulo sort incoming mutations the same as accumulo
Modified:
incubator/accumulo/branches/1.4/src/core/src/main/java/org/apache/accumulo/core/client/mock/MockTable.java
incubator/accumulo/branches/1.4/src/core/src/test/java/org/apache/accumulo/core/client/mock/MockConnectorTest.java
Modified: incubator/accumulo/branches/1.4/src/core/src/main/java/org/apache/accumulo/core/client/mock/MockTable.java
URL: http://svn.apache.org/viewvc/incubator/accumulo/branches/1.4/src/core/src/main/java/org/apache/accumulo/core/client/mock/MockTable.java?rev=1227269&r1=1227268&r2=1227269&view=diff
==============================================================================
--- incubator/accumulo/branches/1.4/src/core/src/main/java/org/apache/accumulo/core/client/mock/MockTable.java (original)
+++ incubator/accumulo/branches/1.4/src/core/src/main/java/org/apache/accumulo/core/client/mock/MockTable.java Wed Jan 4 19:16:25 2012
@@ -69,9 +69,9 @@ public class MockTable {
if (o instanceof MockMemKey) {
MockMemKey other = (MockMemKey) o;
if (count < other.count)
- return -1;
- if (count > other.count)
return 1;
+ if (count > other.count)
+ return -1;
} else {
return 1;
}
Modified: incubator/accumulo/branches/1.4/src/core/src/test/java/org/apache/accumulo/core/client/mock/MockConnectorTest.java
URL: http://svn.apache.org/viewvc/incubator/accumulo/branches/1.4/src/core/src/test/java/org/apache/accumulo/core/client/mock/MockConnectorTest.java?rev=1227269&r1=1227268&r2=1227269&view=diff
==============================================================================
--- incubator/accumulo/branches/1.4/src/core/src/test/java/org/apache/accumulo/core/client/mock/MockConnectorTest.java (original)
+++ incubator/accumulo/branches/1.4/src/core/src/test/java/org/apache/accumulo/core/client/mock/MockConnectorTest.java Wed Jan 4 19:16:25 2012
@@ -278,6 +278,7 @@ public class MockConnectorTest {
assertEquals(value, next.getValue().toString());
}
+ @Test
public void testMockMultiTableBatchWriter() throws Exception {
Connector c = new MockConnector("root");
c.tableOperations().create("a");
@@ -299,6 +300,7 @@ public class MockConnectorTest {
count++;
}
assertEquals(1, count);
+ count = 0;
scanner = c.createScanner("b", Constants.NO_AUTHS);
for (@SuppressWarnings("unused")
Entry<Key,Value> entry : scanner) {
@@ -307,5 +309,27 @@ public class MockConnectorTest {
assertEquals(1, count);
}
+
+ @Test
+ public void testUpdate() throws Exception {
+ Connector c = new MockConnector("root");
+ c.tableOperations().create("test");
+ BatchWriter bw = c.createBatchWriter("test", 1000, 1000l, 1);
+
+ for (int i = 0; i < 10; i++) {
+ Mutation m = new Mutation("r1");
+ m.put("cf1", "cq1", "" + i);
+ bw.addMutation(m);
+ }
+
+ bw.close();
+
+ Scanner scanner = c.createScanner("test", Constants.NO_AUTHS);
+
+ Entry<Key,Value> entry = scanner.iterator().next();
+
+ assertEquals("9", entry.getValue().toString());
+
+ }
}