You are viewing a plain text version of this content. The canonical link for it is here.

Posted to dev@spark.apache.org by Zoltán Zvara <zo...@gmail.com> on 2015/06/30 16:59:21 UTC

DStream.reduce

Why is reduce in DStream implemented with a map, reduceByKey and another
map, given that we have an RDD.reduce?