You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@cassandra.apache.org by br...@apache.org on 2014/05/14 21:33:46 UTC
[3/6] git commit: Fix pig tests.
Fix pig tests.
Patch by Alex Liu, reviewed by brandonwilliams for CASSANDRA-6877
Project: http://git-wip-us.apache.org/repos/asf/cassandra/repo
Commit: http://git-wip-us.apache.org/repos/asf/cassandra/commit/b927f790
Tree: http://git-wip-us.apache.org/repos/asf/cassandra/tree/b927f790
Diff: http://git-wip-us.apache.org/repos/asf/cassandra/diff/b927f790
Branch: refs/heads/trunk
Commit: b927f790af0d20fe8d2453d50ecce25bb6c6e4d0
Parents: 2092da0
Author: Brandon Williams <br...@apache.org>
Authored: Wed May 14 14:32:45 2014 -0500
Committer: Brandon Williams <br...@apache.org>
Committed: Wed May 14 14:32:45 2014 -0500
----------------------------------------------------------------------
test/pig/org/apache/cassandra/pig/CqlTableTest.java | 14 +++++++-------
1 file changed, 7 insertions(+), 7 deletions(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/cassandra/blob/b927f790/test/pig/org/apache/cassandra/pig/CqlTableTest.java
----------------------------------------------------------------------
diff --git a/test/pig/org/apache/cassandra/pig/CqlTableTest.java b/test/pig/org/apache/cassandra/pig/CqlTableTest.java
index 3bbc3d1..15d49f2 100644
--- a/test/pig/org/apache/cassandra/pig/CqlTableTest.java
+++ b/test/pig/org/apache/cassandra/pig/CqlTableTest.java
@@ -177,18 +177,18 @@ public class CqlTableTest extends PigTestBase
pig.registerQuery("STORE recs INTO 'cql://cql3ks/collectiontable?" + defaultParameters + "&output_query=update+cql3ks.collectiontable+set+n+%3D+%3F' USING CqlStorage();");
pig.executeBatch();
- //(book2,((key2, value2),(m,mm),(n,nn)))
- //(book3,((key3, value3),(m,mm),(n,nn)))
- //(book4,((key4, value4),(m,mm),(n,nn)))
- //(book1,((key1, value1),(m,mm),(n,nn)))
+ //(book2,((m,mm),(n,nn)))
+ //(book3,((m,mm),(n,nn)))
+ //(book4,((m,mm),(n,nn)))
+ //(book1,((m,mm),(n,nn)))
pig.registerQuery("result= LOAD 'cql://cql3ks/collectiontable?" + defaultParameters + "' USING CqlStorage();");
Iterator<Tuple> it = pig.openIterator("result");
while (it.hasNext()) {
Tuple t = it.next();
Tuple t1 = (Tuple) t.get(1);
- Assert.assertEquals(t1.size(), 3);
- Tuple element1 = (Tuple) t1.get(1);
- Tuple element2 = (Tuple) t1.get(2);
+ Assert.assertEquals(t1.size(), 2);
+ Tuple element1 = (Tuple) t1.get(0);
+ Tuple element2 = (Tuple) t1.get(1);
Assert.assertEquals(element1.get(0), "m");
Assert.assertEquals(element1.get(1), "mm");
Assert.assertEquals(element2.get(0), "n");