Check the type of dstream before doing reduceByKey.
Check the type of dstream before doing reduceByKey.

If it's already of type JavaPairDStream, there's no need to map
identity PairFunction over it. Doing so causes untuple in the next step
to not work correctly

chetmancini/flambo,cswaroop/sparkling,gorillalabs/sparkling,chrisbetz/sparkling,antonoal/sparkling,jbtv/sparkling,antonoal/sparkling,jbtv/sparkling,cswaroop/sparkling,chrisbetz/sparkling,senor-hadoop/flambo,gorillalabs/sparkling,yieldbot/flambo,jbtv/sparkling,cswaroop/sparkling,anujsrc/flambo,chrisbetz/sparkling,gorillalabs/sparkling,arzig/flambo,cswaroop/sparkling,antonoal/sparkling,gorillalabs/sparkling,antonoal/sparkling,gorillalabs/sparkling,chrisbetz/sparkling,QAston/flambo,jbtv/sparkling,kul/flambo