You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@tinkerpop.apache.org by sp...@apache.org on 2018/03/07 20:09:07 UTC
tinkerpop git commit: Removed some dead/println code from test CTR
Repository: tinkerpop
Updated Branches:
refs/heads/tp32 c1de9f2d0 -> 03a96f896
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/03a96f89
Tree: http://git-wip-us.apache.org/repos/asf/tinkerpop/tree/03a96f89
Diff: http://git-wip-us.apache.org/repos/asf/tinkerpop/diff/03a96f89
Branch: refs/heads/tp32
Commit: 03a96f89609b7a84e10b2c02e35f022b6fd1e05e
Parents: c1de9f2
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:08:27 2018 -0500
----------------------------------------------------------------------
.../process/computer/SparkMessengerTest.java | 21 ++++----------------
1 file changed, 4 insertions(+), 17 deletions(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/tinkerpop/blob/03a96f89/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