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
- Using rdd methods with Dstream Laeeq Ahmed
- Re: Using rdd methods with Dstream Akhil Das
- Re: Using rdd methods with Dstream Laeeq Ahmed
- Re: Using rdd methods with Dstream Sean Owen
- Re: Using rdd methods with Dstream Laeeq Ahmed
- Re: Using rdd methods with Dstream Tathagata Das
- Re: Using rdd methods with Dstream Laeeq Ahmed