Zoltán Zvara Tue, 30 Jun 2015 08:00:40 -0700
Why is reduce in DStream implemented with a map, reduceByKey and another map, given that we have an RDD.reduce?
