Re: JavaDStream to Dataframe: Java

Hello! While operating the JavaDStream you may use a transform() or foreach() methods, which give you an access to an RDD. JavaDStream dataFrameStream = ctx.textFileStream("source").transform(new Function2() { @Override public JavaRDD call(JavaRDD incomingRdd, Time

JavaDStream to Dataframe: Java

Hi, I m newbie in spark and I want to ask you a simple question. I have an JavaDStream which contains data selected from sql database. something like (id, user, score ...) and I want to convert the JavaDStream to a dataframe . how can I do this with java ? Thank you ᐧ