You are correct in that the type of messages being sent in that
example is String and so reduceFun must operate on String. Being just
an example, it can do any reasonable combining of messages. How
about a + + b?
Or the message could be changed to an Int.
The mapReduceTriplets example above appears to have the same problem.
I think it's worth opening a PR + JIRA for the fix.
On Mon, Mar 2, 2015 at 7:12 AM, Deborah Siegel deborah.sie...@gmail.com wrote:
Hello,
I am running through examples given on
http://spark.apache.org/docs/1.2.1/graphx-programming-guide.html
The section for Map Reduce Triplets Transition Guide (Legacy) indicates that
one can run the following .aggregateMessages code
val graph: Graph[Int, Float] = ...
def msgFun(triplet: EdgeContext[Int, Float, String]) {
triplet.sendToDst(Hi) }
def reduceFun(a: Int, b: Int): Int = a + b
val result = graph.aggregateMessages[String](msgFun, reduceFun)
I created a graph of the indicated type, and get an error
scala val result = graph.aggregateMessages[String](msgFun, reduceFun)
console:23: error: type mismatch;
found : Int
required: String
Error occurred in an application involving default arguments.
val result = graph.aggregateMessages[String](msgFun, reduceFun)
^
What is this example supposed to do? The following would work, although I'll
admit I am perplexed by the example's intent.
def msgFun(triplet: EdgeContext[Int, Float, (Int,String)]) {
triplet.sendToDst(1, Hi)
}
def reduceFun(a: (Int,String), b: (Int,String)): (Int,String) = ((a._1 +
b._1),a._2)
val result = graph.aggregateMessages[(Int,String)](msgFun, reduceFun)
Sincerely,
Deb
-
To unsubscribe, e-mail: user-unsubscr...@spark.apache.org
For additional commands, e-mail: user-h...@spark.apache.org
