Repository: tinkerpop Updated Branches: refs/heads/master abc11c872 -> 26c7c1fb5
Removed some dead/println code from test CTR Project: http://git-wip-us.apache.org/repos/asf/tinkerpop/repo Commit: http://git-wip-us.apache.org/repos/asf/tinkerpop/commit/f31a8902 Tree: http://git-wip-us.apache.org/repos/asf/tinkerpop/tree/f31a8902 Diff: http://git-wip-us.apache.org/repos/asf/tinkerpop/diff/f31a8902 Branch: refs/heads/master Commit: f31a8902121d274245b9d9e9527ca75a892771be Parents: 2c6c151 Author: Stephen Mallette <sp...@genoprime.com> Authored: Wed Mar 7 15:05:12 2018 -0500 Committer: Stephen Mallette <sp...@genoprime.com> Committed: Wed Mar 7 15:05:12 2018 -0500 ---------------------------------------------------------------------- .../process/computer/SparkMessengerTest.java | 21 ++++---------------- 1 file changed, 4 insertions(+), 17 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/tinkerpop/blob/f31a8902/spark-gremlin/src/test/java/org/apache/tinkerpop/gremlin/spark/process/computer/SparkMessengerTest.java ---------------------------------------------------------------------- diff --git a/spark-gremlin/src/test/java/org/apache/tinkerpop/gremlin/spark/process/computer/SparkMessengerTest.java b/spark-gremlin/src/test/java/org/apache/tinkerpop/gremlin/spark/process/computer/SparkMessengerTest.java index c280ab2..17224a1 100644 --- a/spark-gremlin/src/test/java/org/apache/tinkerpop/gremlin/spark/process/computer/SparkMessengerTest.java +++ b/spark-gremlin/src/test/java/org/apache/tinkerpop/gremlin/spark/process/computer/SparkMessengerTest.java @@ -19,11 +19,9 @@ package org.apache.tinkerpop.gremlin.spark.process.computer; -import com.fasterxml.jackson.databind.ObjectMapper; import org.apache.tinkerpop.gremlin.process.computer.MessageScope; import org.apache.tinkerpop.gremlin.process.traversal.dsl.graph.__; import org.apache.tinkerpop.gremlin.spark.AbstractSparkTest; -import org.apache.tinkerpop.gremlin.structure.Edge; import org.apache.tinkerpop.gremlin.structure.T; import org.apache.tinkerpop.gremlin.structure.Vertex; import org.apache.tinkerpop.gremlin.structure.util.star.StarGraph; @@ -33,29 +31,22 @@ import scala.Tuple2; import java.util.Arrays; import java.util.List; -import java.util.function.BiFunction; /** * @author Dean Zhu */ public class SparkMessengerTest extends AbstractSparkTest { - private static ObjectMapper objectmapper = new ObjectMapper(); @Test public void testSparkMessenger() throws Exception { // Define scopes final MessageScope.Local<String> orderSrcMessageScope = MessageScope.Local - .of(__::inE, new BiFunction<String, Edge, String>() { - @Override - public String apply(String message, Edge edge) { - System.out.println(edge); - if ("mocked_edge_label1".equals(edge.label())) { - return message; - } - return null; + .of(__::inE, (message, edge) -> { + if ("mocked_edge_label1".equals(edge.label())) { + return message; } + return null; }); - final MessageScope.Local<String> inMessageScope = MessageScope.Local.of(__::inE); // Define star graph final StarGraph starGraph = StarGraph.open(); @@ -75,12 +66,8 @@ public class SparkMessengerTest extends AbstractSparkTest { messenger.sendMessage(orderSrcMessageScope, "a"); List<Tuple2<Object, String>> outgoingMessages0 = messenger.getOutgoingMessages(); - System.out.println(objectmapper.writeValueAsString(outgoingMessages0)); Assert.assertEquals("a", outgoingMessages0.get(0)._2()); Assert.assertNull(outgoingMessages0.get(1)._2()); - //messenger.sendMessage(inMessageScope, "a"); - //List<Tuple2<Object, String>> outgoingMessages1 = messenger.getOutgoingMessages(); - //System.out.println(objectmapper.writeValueAsString(outgoingMessages1)); } } \ No newline at end of file
