Sql context is pre-defimed as sqlc, you may use that.
Cheers!
On 2015년 3월 6일 (금) 02:54 VISHNU SUBRAMANIAN
wrote:
> 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 = n
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 sele