One of the icons on the to allow you to schedule the refresh rate of the notebook, chrone schedule. This will show you the new data. As for deprected api, check which spark version you are running (sc.version) and match the api to it. Hth, Eran
בתאריך שבת, 11 ביולי 2015, 06:27 מאת Xu (Simon) Chen <xche...@gmail.com>: > 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 >>> >> >> >
