0
我使用scala在spark中創建數據源。我有一個案例類,並創建了一個RDD並將其註冊爲一個表。就像火花文檔中給出的例子一樣。無法從impala/hive/spark sql訪問「spark註冊表」
val sqlContext = new org.apache.spark.sql.SQLContext(sc)
import sqlContext.createSchemaRDD
case class Person(name: String, age: Int)
val people = sc.textFile("examples/src/main/resources/people.txt").map(_.split(",")).map(p => Person(p(0), p(1).trim.toInt))
people.registerAsTable("people")
val teenagers = sqlContext.sql("SELECT name FROM people WHERE age >= 13 AND age <= 19")
teenagers.map(t => "Name: " + t(0)).collect().foreach(println)
但是我無法訪問配置單元,impala或spark-sql中的表。 「顯示錶格」命令不顯示錶格。任何想法如何實現這一目標?
謝謝!