如何在 Spark SQL 查询中将架构和表名称作为变量传递

Question

直接在查询中传递 schema_name.table_name 并将 schema_name.table 名称作为变量传递时，我得到不同的结果 例如

Variable1="schema_name.table_name"

Val query1=spark.sql(s""" select* from $variable1""")

Val query2=spark.sql(select * From schema_name.table_name)

我得到的查询 1 和查询 2 的结果不同

我尝试过字符串插值和 f 字符串，但没有一个对我有用

Answer 1

请使用 Valquery1=spark.sql(f""" 从 {variable1}""" 选择 *)