From aa24b0bbe8d0f15d8edae5c1caf5da14de4a5607 Mon Sep 17 00:00:00 2001
From: Ankur Dave <ankurdave@gmail.com>
Date: Sat, 9 Nov 2013 04:23:38 -0800
Subject: [PATCH] Add test for mapReduceTriplets in GraphSuite
---
.../scala/org/apache/spark/graph/GraphSuite.scala | 12 ++++++++++++
1 file changed, 12 insertions(+)
diff --git a/graph/src/test/scala/org/apache/spark/graph/GraphSuite.scala b/graph/src/test/scala/org/apache/spark/graph/GraphSuite.scala
index 782e337504..9c22608554 100644
--- a/graph/src/test/scala/org/apache/spark/graph/GraphSuite.scala
+++ b/graph/src/test/scala/org/apache/spark/graph/GraphSuite.scala
@@ -33,6 +33,18 @@ class GraphSuite extends FunSuite with LocalSparkContext {
}
}
+ test("mapReduceTriplets") {
+ withSpark(new SparkContext("local", "test")) { sc =>
+ val n = 3
+ val star = Graph(sc.parallelize((1 to n).map(x => (0: Vid, x: Vid))))
+
+ val neighborDegreeSums = star.mapReduceTriplets(
+ edge => Array((edge.srcId, edge.dstAttr), (edge.dstId, edge.srcAttr)),
+ (a: Int, b: Int) => a + b)
+ assert(neighborDegreeSums.collect().toSet === (0 to n).map(x => (x, n)).toSet)
+ }
+ }
+
test("aggregateNeighbors") {
withSpark(new SparkContext("local", "test")) { sc =>
val n = 3
--
GitLab