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:06:14 UTC
[1/2] tinkerpop git commit: Removed some dead/println code from test
CTR
Repository: tinkerpop
Updated Branches:
refs/heads/tp33 98ad2fd88 -> 812439f5b
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/tp33
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
[2/2] tinkerpop git commit: Merge branch 'tp32' into tp33
Posted by sp...@apache.org.
Merge branch 'tp32' into tp33
Project: http://git-wip-us.apache.org/repos/asf/tinkerpop/repo
Commit: http://git-wip-us.apache.org/repos/asf/tinkerpop/commit/812439f5
Tree: http://git-wip-us.apache.org/repos/asf/tinkerpop/tree/812439f5
Diff: http://git-wip-us.apache.org/repos/asf/tinkerpop/diff/812439f5
Branch: refs/heads/tp33
Commit: 812439f5b1c9f2d00c9132ddc24cbba4c0a051c3
Parents: 98ad2fd f31a890
Author: Stephen Mallette <sp...@genoprime.com>
Authored: Wed Mar 7 15:05:33 2018 -0500
Committer: Stephen Mallette <sp...@genoprime.com>
Committed: Wed Mar 7 15:05:33 2018 -0500
----------------------------------------------------------------------
.../process/computer/SparkMessengerTest.java | 21 ++++----------------
1 file changed, 4 insertions(+), 17 deletions(-)
----------------------------------------------------------------------