Pyspark SQL pivot error

[#1]

Hi All,

i am trying to do pivot on a table registered from a dataframe. sample dataframe is as below.

Fan 2000 USA
Fan 2000 USA
TV 400 India

when i register it as temp view like this df.createOrReplaceTempView("pivot_test")

and use query

spark.sql("SELECT * FROM pivot_test \
where Country IN ('India','USA')").show()...it works fine.

but below pivot query is giving me error. i think, i am doing some mistake in indentation or the code itself. can someone please help?

spark.sql("SELECT * FROM pivot_test \
pivot(sum(Amount)FOR Country IN ('India','USA'))").show()

ERROR : pyspark.sql.utils.ParseException: u"\nmismatched input 'FROM' expecting <EOF>(line 1, pos 9)\n\n== SQL ==\nSELECT * FROM pivot_test pivot(sum(Amount)FOR Country IN ('India','USA'))\n---------^^^\n"

Thanks in advance.