小编use*_*130的帖子

我们如何使用Scala中的Spark动态地将列名和操作符名称传递给SQL查询？

我试过(不成功)以下内容:

spark.sql("set key_tbl=mytable")
spark.sql("select count(1) from ${key_tbl}").collect()