PySpark : RegisterTempTable 헤더가 손실됩니다

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(...)