数据集 person = spark.read.textfile(path).map(Person::new,Encoders.bean(Person.class))
当我在上面尝试时,它将在 spark2.4(scala-2.11) 中工作,但在 spark3.1.1(scala-2.12) 中,它对于 DataSet 类型显示为模棱两可。而且我在哪里使用地图,过滤器,地图分区,平面地图变得模棱两可/
但是通过进行类型转换,所有转换都会成功 spark.read.textfile(path).map((MapFunction<String,Person>)Person::new,Encoders.bean(Person.class))
有没有其他方法没有类型转换/代码更改