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,
Time, JavaRDD>() {
@Override
public JavaRDD call(JavaRDD incomingRdd, Time
batchTim
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
ᐧ