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

Reply via email to