Since I am on this topic... A few questions.
I'm looking at this tutorial too:
http://zeppelin-project.org/docs/tutorial/tutorial.html
What exactly do I get from this twitter/streaming notebook? Would the
notebook refresh automatically to display the results of the SQL queries?
Also, I thought registerAsTable is now deprecated; I tried using
registerTempTable in the example, something like,
twt.map(...).foreachRDD(rdd => rdd.toDF.registerTempTable("data")).
When I try to query "data" table, I get "no such table List(data)".
Any ideas?
Thanks.
-Simon
On Fri, Jul 10, 2015 at 11:04 PM, Xu (Simon) Chen <xche...@gmail.com> wrote:
> The problem is that kafka gets imported via "import
> org.apache.spark.streaming._", and "import kafka.serializer.StringDecoder"
> fails. You should remove the first line and only import the classes you
> need.
>
> On Fri, Jul 10, 2015 at 8:13 PM, Ignacio Alvarez <ignacioalv...@gmail.com>
> wrote:
>
>> Hi guys,
>>
>> does Zeppelin support writing Spark Streaming applications consuming from
>> Kafka?
>>
>> I tried importing the Kafka dependency directly as in the twitter
>> tutorial but it didn't get recognized. I though i'd ask before checking
>> further:
>>
>> [image: Inline image 1]
>> Thanks,
>>
>> Ignacio
>>
>
>
