I'm trying to write some unit tests for my spark code. I need to pass a JavaPairDStream<String, String> to my spark class.
Is there a way to create a JavaPairDStream using Java API? Also is there a good resource that covers an approach (or approaches) for unit testing using Java. Regards jk
