Spark SQL, передающий переменную

Question

У меня есть следующий код Spark и я хочу передать ему переменную. Как это сделать? Я пробовал следовать.

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

Answer 1

Вы почти там просто пропустил s :)

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

Answer 2

Вы можете передать строку в SQL заявление, как показано ниже

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