Hi,
I normally use dstream.transform whenever I need to use methods which are 
available in RDD API but not in streaming API. e.g. dstream.transform(x => 
x.sortByKey(true))
But there are other RDD methods which return types other than RDD. e.g. 
dstream.transform(x => x.top(5)) top here returns Array. In the second 
scenario, how can i return RDD rather than array, so that i can perform further 
steps on dstream.
Regards,
Laeeq

Reply via email to