Hi,

I am using Kafka with Apache Stream to send JSON to Apache Spark:

val messages = KafkaUtils.createDirectStream[String, String,
StringDecoder, StringDecoder](ssc, kafkaParams, topicsSet)

Now, I want parse the DStream created to DataFrame, but I don't know if
Spark 1.3 have some easy way for this. ¿Any suggestion? I can get the
message with:

val lines = messages.map(_._2)

Thank u for all. Sergio J.

Reply via email to