如何在Spark中声明一个空的数据集？

Question

我是Spark和Spark数据集中的新手。我试图使用声明一个空的数据集，emptyDataset但它要求org.apache.spark.sql.Encoder。我用于数据集的数据类型是的对象case class Tp(s1: String, s2: String, s3: String)。

Answer 1

您所需要做的就是在创建空数据集之前从 SparkSession 实例导入隐式编码器：请参阅此处的import spark.implicits._ 完整示例