spark-user mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From Mohit Durgapal <>
Subject how do you convert directstream into data frames
Date Fri, 14 Aug 2015 04:41:35 GMT
Hi All,

After creating a direct stream like below:

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

I would like to convert the above stream into data frames, so that I could
run hive queries over it. Could anyone please explain how this can be
achieved? I am using spark version 1.3.0

View raw message