スパークSQL - 私は、次のコマンドを実行します

Question

が見つかりません一時テーブルを登録：その後、私はREPLでこのコードを実行

sc.stop 

：

spark-shell --packages datastax:spark-cassandra-connector:1.6.0-s_2.10 

その後、私はコンテキストを停止

val conf = new org.apache.spark.SparkConf(true).set("spark.cassandra.connection.host", "127.0.0.1") 
val sc = new org.apache.spark.SparkContext(conf) 
val sqlContext = new org.apache.spark.sql.SQLContext(sc) 
val cc = new org.apache.spark.sql.cassandra.CassandraSQLContext(sc) 

cc.setKeyspace("ksp") 

cc.sql("SELECT * FROM continents").registerTempTable("conts") 

val allContinents = sqlContext.sql("SELECT * FROM conts").collect 

そして、私は：

org.apache.spark.sql.AnalysisException: Table not found: conts; 

キースペースkspとテーブルcontinentsはCassandraで定義されているので、その側からのエラーではないと思われます。あなたがデータフレームを作成するための別のコンテキストを使用してSQLを実行しているので

（スパーク1.6.0,1.6.1）

Answer 1

。

val conf = new 
org.apache.spark.SparkConf(true).set("spark.cassandra.connection.host", "127.0.0.1") 
val sc = new org.apache.spark.SparkContext(conf) 
val sqlContext = new org.apache.spark.sql.SQLContext(sc) 
val cc = new org.apache.spark.sql.cassandra.CassandraSQLContext(sc) 

cc.setKeyspace("ksp") 

cc.sql("SELECT * FROM continents").registerTempTable("conts") 

// use cc instead of sqlContext 
val allContinents = cc.sql("SELECT * FROM conts").collect