[1/3] tinkerpop git commit: Removed some dead/println code from test CTR
Repository: tinkerpop
Updated Branches:
refs/heads/master 26c7c1fb5 -> 25ae1a1ea
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/master
Commit: 03a96f89609b7a84e10b2c02e35f022b6fd1e05e
Parents: c1de9f2
Author: Stephen Mallette
Authored: Wed Mar 7 15:05:12 2018 -0500
Committer: Stephen Mallette
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 orderSrcMessageScope =
MessageScope.Local
-.of(__::inE, new BiFunction() {
-@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 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> 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> outgoingMessages1 =
messenger.getOutgoingMessages();
-
//System.out.println(objectmapper.writeValueAsString(outgoingMessages1));
}
}
\ No newline at end of file
[1/3] tinkerpop git commit: Removed some dead/println code from test CTR
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
Authored: Wed Mar 7 15:05:12 2018 -0500
Committer: Stephen Mallette
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 orderSrcMessageScope =
MessageScope.Local
-.of(__::inE, new BiFunction() {
-@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 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> 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> outgoingMessages1 =
messenger.getOutgoingMessages();
-
//System.out.println(objectmapper.writeValueAsString(outgoingMessages1));
}
}
\ No newline at end of file
