Has*_*Ali 5 scala apache-spark apache-spark-sql
我是Spark和Spark数据集中的新手。我试图使用声明一个空的数据集，emptyDataset但它要求org.apache.spark.sql.Encoder。我用于数据集的数据类型是的对象case class Tp(s1: String, s2: String, s3: String)。
emptyDataset
org.apache.spark.sql.Encoder
case class Tp(s1: String, s2: String, s3: String)
Vit*_*nko 4
您所需要做的就是在创建空数据集之前从 SparkSession 实例导入隐式编码器：请参阅此处的import spark.implicits._ 完整示例
import spark.implicits._
归档时间：
8 年，1 月 前
查看次数：
11100 次
最近记录：