На Scala как передать параметры в файл с инструкциями sql и использовать sqlContext.sql?

Question

Мой sql-запрос длинный и хранится в файле.Я хотел бы сделать предложение where динамическим путем передачи параметров.В Scala я хотел бы выполнить это с помощью spark sqlcontext.sql (queryfile).Пожалуйста, помогите.

val FromDate = "2019-02-25"

val sqlfile = fromFile("queryfile").getLines.mkString

val result = sqlContext.sql(sqlfile)

На файл, который я имею:

Select col1, col2 from table1 where transdate = '${FromDate}'

Answer 1

Это просто, используйте метод замены scala:

val FromDate = "2019-02-25"
val s = "Select col1, col2 from table1 where transdate = '${FromDate}'"
val withParameters= s.replace("${FromDate}",FromDate )
println(withParameters)
val result = sqlContext.sql(withParameters)