如何用spark中的视图替换某些表名

a5g8bdjr  于 2021-05-27  发布在  Spark
关注(0)|答案(0)|浏览(298)

我有如下spark SQL:

select * from db::table;

但是spark无法识别 db::table ,所以我尝试以下策略
使用自定义函数加载 db::table 变成一个 DataFrame ```
val str = "db::table"
val Array(db, table) = str.split("::")
val df:DataFrame = mySelfDefinedFunction(str)

从创建视图 `df` ```
df.createOrReplaceTempView(s"${db}_${table}")

替换所有出现的 db::tabledb_table 我发现也许有一些解决方案可以通过编写一个类来处理这个问题 ParserInterface ,并重写它的某些方法。但我不知道怎么做。

暂无答案!

目前还没有任何答案,快来回答吧!

相关问题