动态sql也可以从scala对象创建。根据用户输入，首先创建一个rdd。然后根据您的需求创建一个预期对象的列表，并创建一个Dataframe和对象名的Map。然后使用循环生成sql字符串。

嘿，我通过创建一个名为generatedf的方法实现了这一点，如下所示。这是将文件列表作为字符串（“，”分隔）和模式定义（“，”）分隔的文件，最后是将包含数据的文件。

def generateDF(fName: String, schemaFile: String, dataFile: String): Unit = {
// Reading the prod files and creating DataFrame from user defined schema
val SchemaRDD = spark.sparkContext.textFile(schemaFile)
val SchemaString = SchemaRDD.map(_.toString).collect().mkString
val Schema = StructType(SchemaString.split(",").map(column => StructField(column.split(":")(0), inferType(column), true)))
val outDF = spark.read.format("csv")
  .option("delimiter", ",").option("quote", "")
  .option("header", "false")
  .schema(Schema)
  .load(dataFile)
outDF.createTempView(fName)

}
//为源文件中的每个表名调用过程

fileListRDD
      .flatMap(_.split(",")).collect.toList
      .map(file => generateDF(file.mkString.toString, (filePath + file.mkString + ".schema"), (filePath + file.mkString + ".csv")))