1
私はスカラの初心者です。Scala - RDDをマップに変換する
私は属性の1つとしてuserIdを含むクラスUserを持っています。 userIdをキーとし、userを値として、ユーザーのRDDをマップに変換したいと考えています。
ありがとうございます！
A
答えて
1
RDD myUsers:RDD[Users]があるとします。 RDDの各レコードには、属性userIdが含まれています。あなたが地図にnewRddを変換したい場合は
val newRdd = myUsers.map(x => (x.userId, x))
：あなたはnewRddには、この方法でそれを変換することができ
val myMap = newRdd.toMap
あなたは1行でこれら二つの計算を行うことができ、私はちょうどのためにそれらを分割さ説明
+1
ありがとうございます:) –
関連する問題
- 1. Scala Iterable [tuple]をRDDに変換
- 2. spark scala rdd sql行をベクトルに変換
- 3. Scalaのマップをjavaに変換する
- 4. JavaマップをJavaコードのScala不変マップに変換する
- 5. java.lang.NumberFormatException：マップを使用して、このRDDを変換しながら、RDD
- 6. Scala-Spark：データフレームをRDDに変換する[Edge]
- 7. 2dリストをRDD [vector]またはJavaRDD [vector] scalaに変換する
- 8. RDD [Double]をScalaのVectorに変換する方法Spark
- 9. RDD [（String、String）]をRDD [Array [String]]に変換する方法は？
- 10. マップ変換のパフォーマンスspark dataframeとRDD
- 11. rddのリストをpythonのマップに変換するには？
- 12. CSVをRDDに変換し、Spark/Scalaで読み取る
- 13. RDD [List [String]]をRDDに変換する方法
- 14. RDD [org.apache.spark.sql.Row]からRDD [org.apache.spark.mllib.linalg.Vector]への変換
- 15. ローカルベクトルをRDDに変換する[ベクトル]
- 16. 行rddを型付きrddに変換する方法
- 17. ScSparでPySpark RDDを変換する
- 18. Array RDDをSparkのList RDDに変換できない
- 19. データフレームに変換ScalaのFP-成長RDD出力
- 20. Scala - RDDを別のマップで更新する
- 21. RDDを変換する 'take'
- 22. pyspark：RDDに変換RDD
- 23. Scala Spark DF→RDDを変換中に型を保持する方法は？
- 24. apache ignite rddをscalaのspdd rddに変換することは可能ですか？
- 25. Scala Map [String、List [String]]をマップ[String、String]に変換する
- 26. Java列挙をScalaマップに変換する
- 27. Scalaで配列[VertexIds]をマップに変換する方法は？ Scalaで
- 28. Scala/SPARKでDataframeをRDDに変換する効率的な方法は？
- 29. Spark-ScalaでListまたはRDDのリストをDataFrameに変換する
- 30. Scalaは：RDD [LabelledPoint] RDD [（ロング、ベクトル）]
ペア（ 'userId'、' user'）でRDDを作成してから、 – edkeveked
の後にマップに変換することができます。ありがとうございました –