Why does the reduce function only work on sums of keys of the same type and does not support other functional forms?
I am having trouble in another example where instead of 1s and 0s, the output of the map function is something like A=(1,2) and B=(3,4). I need a reduce function that can return something complicated based on reduce( (A,B) => (arbitrary fcn1 of A and B, arbitrary fcn2 of A and B) ), but I am only getting reduce( (A,B) => (arbitrary fcn1 of A, arbitrary fcn2 of A) ). See http://apache-spark-developers-list.1001551.n3.nabble.com/reduce-only-removes-duplicates-cannot-be-arbitrary-function-td6606.html -- View this message in context: http://apache-spark-developers-list.1001551.n3.nabble.com/Scala-examples-for-Spark-do-not-work-as-written-in-documentation-tp6593p6607.html Sent from the Apache Spark Developers List mailing list archive at Nabble.com.
