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