scala 空的dataframe插入数据

要向一个空的 DataFrame 插入数据，你可以使用 `withColumn` 方法来添加新的列，并为新的列提供数据。以下是一个示例：

import org.apache.spark.sql.{SparkSession, Row}
import org.apache.spark.sql.types._

// 创建 SparkSession
val spark = SparkSession.builder()
  .appName("InsertDataIntoEmptyDataFrame")
  .master("local")
  .getOrCreate()

// 定义数据结构和模式
val schema = StructType(Seq(
  StructField("id", IntegerType),
  StructField("name", StringType)
))

// 创建一个空的 DataFrame
val emptyDF = spark.createDataFrame(spark.sparkContext.emptyRDD[Row], schema)

// 创建要插入的数据
val data = Seq(
  Row(1, "Alice"),
  Row(2, "Bob"),
  Row(3, "Charlie")
)

// 将数据添加到 DataFrame 中
val newDataDF = spark.createDataFrame(spark.sparkContext.parallelize(data), schema)

// 合并原始空的 DataFrame 和新的包含数据的 DataFrame
val resultDF = emptyDF.union(newDataDF)

// 展示结果
resultDF.show()

在这个示例中，首先我们创建了一个空的 DataFrame `emptyDF`，然后定义了一个与我们要插入的数据匹配的模式 `schema`。接下来，我们创建了要插入的数据 `data`，并使用 `createDataFrame` 方法将其转换为 DataFrame。

最后，我们使用 `union` 方法将原始空的 DataFrame 和包含数据的新 DataFrame 进行合并，得到最终的结果 DataFrame `resultDF`。你可以使用 `show` 方法来查看最终结果。