If anyone runs into the same issue, I found a workaround:
>>> df.where('state_code = "NY"')
works for me.
>>> df.where(df.state_code == "NY").collect()
fails with the error from the first post.
--
View this message in context:
http://apache-spark-user-list.1001560.n3.nabble.com/Spark-SQL-1-3-not-finding-attribute-in-DF-tp25599p25600.html
Sent from the Apache Spark User List mailing list archive at Nabble.com.
---------------------------------------------------------------------
To unsubscribe, e-mail: user-unsubscr...@spark.apache.org
For additional commands, e-mail: user-h...@spark.apache.org
