PySpark：RegisterTempTable Headersを失う

Question

私はSQLContextを使ってデータを読み込んで、SQLクエリを実行しようとしています。私はエラーを受け取りました。私は適切にWHERE句を記述することはできませんので

%pyspark 

from pyspark.sql import SQLContext 
sqlCtx = SQLContext(sc) 
data = sqlCtx.read.csv("s3://recs-emr-sandbox/mtcars.csv", header=True, inferSchema=True) 
data.registerTempTable("data") 
spark.sql("SELECT * from data").show() 

私は結果を得るが、私のヘッダがなくなっている、したがって、基本的には役に立たない：ここに私のコードです。

ここで私は間違っていますか？おかげ

Answer 1

あなたが最初のテーブルを登録する必要があります。

data = sqlCtx.read.csv(...) 
df.registerTempTable("data") 
sqlContext.sql(...)