ananth3010
Results
3
comments of
ananth3010
#216 has this resolved. Is there a documentation on how to use this?
#201 confirms this. Pasting it here for others benefit: You can do this with DStream.foreachRDD { rdd => df = rddToDataFrame(rdd) }
Could you please confirm if the below approach is right? I am not able to create a DF after pulling your code. DStream.foreachRDD { rdd => df = rddToDataFrame(rdd) }