spark-user mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From Mohit Durgapal <durgapalmo...@gmail.com>
Subject Re: how do you convert directstream into data frames
Date Fri, 14 Aug 2015 05:15:36 GMT
Any idea anyone?

On Fri, Aug 14, 2015 at 10:11 AM, Mohit Durgapal <durgapalmohit@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
>

Mime
View raw message