如何将两个RDD合并到一个RDD
问题描述:
帮助,我有两个RDD,我想合并到一个RDD.这是我的代码.
Help ,I have two RDDs, i want to merge to one RDD.This is my code.
val us1 = sc.parallelize(Array(("3L"), ("7L"),("5L"),("2L")))
val us2 = sc.parallelize(Array(("432L"), ("7123L"),("513L"),("1312L")))
答
只需使用union:
val merged = us1.union(us2)
文档为 Scala中的快捷方式是:
Shotcut in Scala is:
val merged = us1 ++ us2