Scala Spark - flatMapでSeq [double]の符号を変換する

Question

FlatMap内でSeq [double]の符号を変更しようとしています。タイプの不一致エラーが発生します。

import util.Random.nextDouble 
var numbers = Seq.fill(1000)(nextDouble) 
val nrdd = sc.parallelize(numbers)  
val mrdd = nrdd.flatMap(a => (a)* -1.0) 

Answer 1

私はあなたが単に代わりflatMapのmap方法を探していると思います。

val mrdd = nrdd.map(a => -a)