我有如下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::table
至 db_table
我发现也许有一些解决方案可以通过编写一个类来处理这个问题 ParserInterface
,并重写它的某些方法。但我不知道怎么做。
暂无答案!
目前还没有任何答案,快来回答吧!