diff options
Diffstat (limited to 'bagel/src/test/scala')
| -rw-r--r-- | bagel/src/test/scala/bagel/BagelSuite.scala | 10 |
1 files changed, 2 insertions, 8 deletions
diff --git a/bagel/src/test/scala/bagel/BagelSuite.scala b/bagel/src/test/scala/bagel/BagelSuite.scala index 72aecb7fd8..29f5f0c358 100644 --- a/bagel/src/test/scala/bagel/BagelSuite.scala +++ b/bagel/src/test/scala/bagel/BagelSuite.scala @@ -20,10 +20,7 @@ class BagelSuite extends FunSuite with Assertions { val msgs = sc.parallelize(Array[(String, TestMessage)]()) val numSupersteps = 5 val result = - Pregel.run(sc, verts, msgs, - Pregel.defaultCreateCombiner[TestMessage], - Pregel.defaultMergeMsg[TestMessage], - Pregel.defaultMergeCombiners[TestMessage], 1) { + Pregel.run(sc, verts, msgs, new DefaultCombiner[TestMessage], 1) { (self: TestVertex, msgs: Option[ArrayBuffer[TestMessage]], superstep: Int) => (new TestVertex(self.id, superstep < numSupersteps - 1, self.age + 1), Array[TestMessage]()) } @@ -37,10 +34,7 @@ class BagelSuite extends FunSuite with Assertions { val msgs = sc.parallelize(Array("a" -> new TestMessage("a"))) val numSupersteps = 5 val result = - Pregel.run(sc, verts, msgs, - Pregel.defaultCreateCombiner[TestMessage], - Pregel.defaultMergeMsg[TestMessage], - Pregel.defaultMergeCombiners[TestMessage], 1) { + Pregel.run(sc, verts, msgs, new DefaultCombiner[TestMessage], 1) { (self: TestVertex, msgs: Option[ArrayBuffer[TestMessage]], superstep: Int) => val msgsOut = msgs match { |