3
Spark RDD[Array[MyObject]]
をRDD[MyObject]
に変換するにはどうすればよいですか?あなたがRDD.flatMap
を探しているSpark RDD [Array [MyObject]]をRDDに変換する方法[MyObject]
Spark RDD[Array[MyObject]]
をRDD[MyObject]
に変換するにはどうすればよいですか?あなたがRDD.flatMap
を探しているSpark RDD [Array [MyObject]]をRDDに変換する方法[MyObject]
:
val flattened: RDD[MyObject] = rdd.flatMap(identity)
私はあなたがお勧め何しようとしたが、flatMap(_)は、パラメータが欠落していることを示す構文エラーを取得します。あなたは小さな例をお聞かせください。ありがとうございます –
@MichaelD今すぐ試してください。 –
私が探していたものとまったく同じです。どうもありがとう!! –