yieldbot/flambo — pull request #25 by viksit (2014-11-05 00:51:25+00:00)
Title: Few changes for Spark Streaming

* Adds filter, print functions
* Changes .map to .mapToPair when using the reduceByKey functionality for a given DStream object, since a cast to JavaPairDStream is needed