Hi,
I am trying to use zeppelin. I executed the below commands.
*import org.apache.spark.sql.SQLContext*
*val rawData = sc.textFile("12345.txt")*
* val sqlContext = new SQLContext(sc)*
* val recordsJson = sqlContext.jsonRDD(rawData)*
* recordsJson.registerTempTable("records")*
*%sql select tz from records*
I get the below error when i put the above code in one paragraph.
*<console>:36: error: not found: value % %sql select tz from records*
I get the below error when I have the last line in a different paragraph.
*%sql select tz from records*
*Table Not Found: records*
I am using the latest version built against spark-1.2
Can some one help me to find what I am missing?
Thanks,
Vishnu
