Я использую файл свойств для передачи sql запроса в spark scala, мой файл свойств выглядит следующим образом.
spark.query=select '$env' from table_name limit 5
В коде spark
val env="dev"
val query=sparkContext.getConf.get("spark.query");
println(query);
spark.sql(s"""$query""");
Но здесь это не говорящее значение для dev мой вывод, как показано ниже:
выберите $env из table_name =>$env значение не заполняется.