Re: how do you convert directstream into data frames

Any idea anyone? On Fri, Aug 14, 2015 at 10:11 AM, Mohit Durgapal wrote: > 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

how do you convert directstream into data frames

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 p