java.lang.IllegalArgumentException:需求失败:列pmi必须是org.apache.spark.ml.linalg.VectorUDT@3bfc3ba7类型,但实际上是DoubleTypeat org.apache.spark.sql.types.StructType$$anonfun$apply$1.apply(StructType.scala:264) at <e
我正在尝试查找基于另一列的特定数组(类型为Double),该列具有最小值。下面的代码可以提取数组,但我无法将其作为Array[Double]接收。已尝试从从其他线程找到的as进行映射和强制转换,但无法解决问题。如果有任何提示,我将不胜感激。= df.filter($"time" === minTime).select($"crds").take(1) found : Ar
我的前提是将文件读取到JavaRDD,并根据ratingsObject映射RDD (对象有两个参数,movieID和rating)。所以我只想打印这个数据集中的第一行。(RDD.scala:288)at org.apache.spark.rdd.RDD.computeOrReadCheckpoint(RDD.scala:324)
at