tinkerpop-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From ok...@apache.org
Subject [3/3] incubator-tinkerpop git commit: fixed up HadoopGremlinPluginTest to use new group() semantics.
Date Tue, 06 Oct 2015 21:03:35 GMT
fixed up HadoopGremlinPluginTest to use new group() semantics.


Project: http://git-wip-us.apache.org/repos/asf/incubator-tinkerpop/repo
Commit: http://git-wip-us.apache.org/repos/asf/incubator-tinkerpop/commit/c0118e32
Tree: http://git-wip-us.apache.org/repos/asf/incubator-tinkerpop/tree/c0118e32
Diff: http://git-wip-us.apache.org/repos/asf/incubator-tinkerpop/diff/c0118e32

Branch: refs/heads/group_step_2
Commit: c0118e32d5c4f09f82c01e54e28d8b1a6cb7b8c7
Parents: 315b1d1
Author: Marko A. Rodriguez <okrammarko@gmail.com>
Authored: Tue Oct 6 15:03:27 2015 -0600
Committer: Marko A. Rodriguez <okrammarko@gmail.com>
Committed: Tue Oct 6 15:03:27 2015 -0600

----------------------------------------------------------------------
 .../spark/groovy/plugin/HadoopGremlinPluginTest.java    | 12 ++++++------
 1 file changed, 6 insertions(+), 6 deletions(-)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/incubator-tinkerpop/blob/c0118e32/spark-gremlin/src/test/java/org/apache/tinkerpop/gremlin/spark/groovy/plugin/HadoopGremlinPluginTest.java
----------------------------------------------------------------------
diff --git a/spark-gremlin/src/test/java/org/apache/tinkerpop/gremlin/spark/groovy/plugin/HadoopGremlinPluginTest.java
b/spark-gremlin/src/test/java/org/apache/tinkerpop/gremlin/spark/groovy/plugin/HadoopGremlinPluginTest.java
index 77d568c..5d27980 100644
--- a/spark-gremlin/src/test/java/org/apache/tinkerpop/gremlin/spark/groovy/plugin/HadoopGremlinPluginTest.java
+++ b/spark-gremlin/src/test/java/org/apache/tinkerpop/gremlin/spark/groovy/plugin/HadoopGremlinPluginTest.java
@@ -31,7 +31,6 @@ import org.apache.tinkerpop.gremlin.process.computer.MapReduce;
 import org.apache.tinkerpop.gremlin.process.computer.traversal.step.sideEffect.mapreduce.TraverserMapReduce;
 import org.apache.tinkerpop.gremlin.process.traversal.Traversal;
 import org.apache.tinkerpop.gremlin.process.traversal.Traverser;
-import org.apache.tinkerpop.gremlin.process.traversal.step.util.BulkSet;
 import org.apache.tinkerpop.gremlin.spark.process.computer.HadoopSparkGraphProvider;
 import org.apache.tinkerpop.gremlin.structure.Vertex;
 import org.apache.tinkerpop.gremlin.util.iterator.IteratorUtils;
@@ -39,6 +38,7 @@ import org.junit.Before;
 import org.junit.Test;
 
 import java.util.Arrays;
+import java.util.Collection;
 import java.util.List;
 
 import static org.junit.Assert.*;
@@ -135,17 +135,17 @@ public class HadoopGremlinPluginTest extends AbstractGremlinTest {
         AbstractGremlinProcessTest.checkResults(Arrays.asList("ripple", "lop"), traversal);
         assertTrue((Boolean) this.console.eval("hdfs.exists('target/test-output/m')"));
         assertTrue((Boolean) this.console.eval("hdfs.exists('target/test-output/" + TraverserMapReduce.TRAVERSERS
+ "')"));
-        final List<KeyValue<Integer, BulkSet<String>>> mList = IteratorUtils.asList(this.console.eval("hdfs.head('target/test-output/m',ObjectWritable)"));
+        final List<KeyValue<Integer, Collection<String>>> mList = IteratorUtils.asList(this.console.eval("hdfs.head('target/test-output/m',ObjectWritable)"));
         assertEquals(4, mList.size());
         mList.forEach(keyValue -> {
             if (keyValue.getKey().equals(29))
-                assertEquals(1l, keyValue.getValue().get("marko"));
+                assertTrue(keyValue.getValue().contains("marko"));
             else if (keyValue.getKey().equals(35))
-                assertEquals(1l, keyValue.getValue().get("peter"));
+                assertTrue(keyValue.getValue().contains("peter"));
             else if (keyValue.getKey().equals(32))
-                assertEquals(1l, keyValue.getValue().get("josh"));
+                assertTrue(keyValue.getValue().contains("josh"));
             else if (keyValue.getKey().equals(27))
-                assertEquals(1l, keyValue.getValue().get("vadas"));
+                assertTrue(keyValue.getValue().contains("vadas"));
             else
                 throw new IllegalStateException("The provided key/value is unknown: " + keyValue);
         });


Mime
View raw message