スパークは、私がスパークSQLContextを使用してデータを読み込み、変数に保存し、すべての

Question

を選択しsqlContext：

val somevar = sqlContext.read.parquet(some_file.parquet) 

それから私は、選択を使用して、すべての値を選択するために何か希望：

somevar.select(*) 

しかし、これを動作しません。

同等は何をするだろう：

somevar.registerTempTable("sometable") 

sqlContext.sql("SELECT * FROM sometable") 

しかし、私は、以前のを行うにはしたくありません。

大切にしてください。

Answer 1

構文エラーがあります。

import sqlContext.implicit._ 

val df = Seq((1,2),(2,3)).toDF 
// df: org.apache.spark.sql.DataFrame = [_1: int, _2: int] 

// solution 1 
df.select("*") 
// res54: org.apache.spark.sql.DataFrame = [_1: int, _2: int] 

// alternative 1 
df.select($"*") 
// res55: org.apache.spark.sql.DataFrame = [_1: int, _2: int] 

// alternative 2 
df.select('*) 
// res56: org.apache.spark.sql.DataFrame = [_1: int, _2: int] 

次の構文を使用し が火花-SQLを使用したすべての列を選択する方法であります