我有一个数组[string],它的值为[“df1”,“df2”,“df3”]
我的配置文件中有如下值。
DF1=select * from TB1
DF2=select * from TB2
DF3=select * from TB3
我需要通过卸载相应的表在for循环中动态创建3个Dataframe。
假设我的数组名是array1。
我的密码是 for (for1 <- ARRAY1){val $for1+_DF = spark.sql(for1)}
上面只是一种伪代码。
请帮助我提供正确的代码语法。
谢谢,纳文
1条答案
按热度按时间rkue9o1l1#
检查以下代码。