yieldbot/flambo — pull request #26 by viksit (2014-11-05 01:26:09+00:00)
Title: Changes .map to .mapToPair when using the reduceByKey functionality

.. for a given DStream object, since a cast to JavaPairDStream is needed.