Hi Guys
Newbie question:
import sys.process._
val jfileRDD = sqlContext.jsonFile(s"file:///mnt/test.json")
val facebook = jfileRDD.toDF()
facebook.show()
facebook.printSchema()
facebook.registerTempTable("facebook")
import sys.process._
warning: there were 1 deprecation warning(s); re-run with -deprecation for
details
jfileRDD: org.apache.spark.sql.DataFrame = [action: string, timestamp: string]
facebook: org.apache.spark.sql.DataFrame = [action: string, timestamp: string]
|action| timestamp|
+------+--------------------+
|create|2016-01-07T00:01:17Z|
+------+--------------------+
Root
|-- action: string (nullable = true)
|-- timestamp: string (nullable = true)
%sql
select action, count(1) value
from facebook
where action = create
ERROR:
org.apache.spark.sql.AnalysisException: Table not found: facebook; line 2 pos 5
What is the matter?
This email is confidential and may be subject to privilege. If you are not the
intended recipient, please do not copy or disclose its content but contact the
sender immediately upon receipt.
