Skip to content
Browse files

re-enable unit test for composites.

  • Loading branch information...
1 parent 32d9237 commit 6baa5e8cdec638909ee1a821d9054e42fb8d1ee0 @ptgoetz ptgoetz committed Feb 11, 2013
Showing with 9 additions and 5 deletions.
  1. +9 −5 src/test/java/com/hmsonline/storm/cassandra/bolt/CompositeTest.java
View
14 src/test/java/com/hmsonline/storm/cassandra/bolt/CompositeTest.java
@@ -143,10 +143,7 @@ public void testTrident() throws Exception {
}
@SuppressWarnings({ "rawtypes", "unchecked" })
-// @Test
- // TODO come back to this -- there seem to be issues with Astyanax and composite columns.
- // see https://github.com/Netflix/astyanax/issues/80
- // see https://github.com/Netflix/astyanax/issues/42
+ @Test
public void testCompositeRangeQuery() throws InterruptedException {
try{
AstyanaxClient client = new AstyanaxClient();
@@ -169,6 +166,12 @@ public void testCompositeRangeQuery() throws InterruptedException {
tuple = newTridentTuple(fields, new Values("my_row", "a", "b", "ab"));
client.writeTuple(tuple, tupleMapper);
+ tuple = newTridentTuple(fields, new Values("my_row", "a", "c", "ac"));
+ client.writeTuple(tuple, tupleMapper);
+
+ tuple = newTridentTuple(fields, new Values("my_row", "a", "d", "ad"));
+ client.writeTuple(tuple, tupleMapper);
+
tuple = newTridentTuple(fields, new Values("my_row", "c", "c", "cc"));
client.writeTuple(tuple, tupleMapper);
@@ -181,7 +184,8 @@ public void testCompositeRangeQuery() throws InterruptedException {
assertNotNull(map.get(new SimpleComposite("a", "a")));
assertNotNull(map.get(new SimpleComposite("a", "b")));
- assertNull(map.get(new SimpleComposite("b", "b")));
+ assertNotNull(map.get(new SimpleComposite("a", "c")));
+ assertNull(map.get(new SimpleComposite("a", "d")));
assertNull(map.get(new SimpleComposite("c", "c")));
assertNull(map.get(new SimpleComposite("d", "d")));
client.stop();

0 comments on commit 6baa5e8

Please sign in to comment.
Something went wrong with that request. Please try again.