Spark SQL传递一个变量

Question

我有跟随Spark sql,我想传递变量.怎么做？我尝试了以下方式.

 sqlContext.sql("SELECT count from mytable WHERE id=$id")

Answer 1

您可以将字符串传递到 sql 语句中，如下所示

id = "1"
query = "SELECT count from mytable WHERE id='{}'".format(id)
sqlContext.sql(query)

Answer 2

你几乎就在那里错过了s:)

sqlContext.sql(s"SELECT count from mytable WHERE id=$id")

Answer 3

由于接受的答案对我不起作用，我正在使用字符串插值编写自己的答案。

sqlContext.sql(s"""SELECT count from mytable WHERE id='${id}'""")