pspark SQL模块不能识别列

Question

我有这样一个数据帧：

| Cid|    Cname| acctype| accnum|country|currency |rank | 
+----+--------------------+--------+--------+-------+---------+-------+ 
|6489| u'Kristi Bradley'| current|62814653|  US|  USD| 296| 
|4204| u'Elizabeth Ande...| current|18476174|  US|  USD| 237| 
|6020| u'Melody Miller'| current|84315491|  US|  USD| 285| 
|9512|  u'William Wise'| deposit|37582740|  US|  USD| 277| 
|7223| u'Jackie Arellano'| current|46939546|  US|  USD| 498| 
|8514| u'Michael Hawkins'| current|90554826|  US|  USD| 498| 
|6075|  u'James Garcia'| current|77363343|  US|  USD|  53| 
|7700| u'Margaret Phill...| deposit|18799392|  US|  USD| 399| 

我pyspark SQL模块的查询是这样的：

result = sqlContext.sql("SELECT sum(rank) FROM US_df WHERE acctype ='current' ") 

但我得到的结果为空这样的：

| _c0| 
+----+ 
|null| 
+----+ 

我在这里做错了什么？

Answer 1

嗨我现在还不能评论，对于简短的回答抱歉。你注册了你的桌子吗？

US_df.createOrReplaceTempView("us_table") 

http://spark.apache.org/docs/latest/sql-programming-guide.html#running-sql-queries-programmatically