在Scala中，如何加入2个RDD

在Scala中，可以通过使用RDD的union方法将两个RDD合并为一个RDD。union方法将两个RDD的元素合并在一起，生成一个包含所有元素的新RDD。

以下是在Scala中如何加入两个RDD的示例代码：

import org.apache.spark.{SparkConf, SparkContext}

object RDDJoinExample {
  def main(args: Array[String]): Unit = {
    // 创建SparkConf对象
    val conf = new SparkConf().setAppName("RDDJoinExample").setMaster("local")
    // 创建SparkContext对象
    val sc = new SparkContext(conf)

    // 创建第一个RDD
    val rdd1 = sc.parallelize(Seq(1, 2, 3, 4, 5))
    // 创建第二个RDD
    val rdd2 = sc.parallelize(Seq(6, 7, 8, 9, 10))

    // 将两个RDD合并为一个RDD
    val joinedRDD = rdd1.union(rdd2)

    // 打印合并后的RDD内容
    joinedRDD.foreach(println)

    // 关闭SparkContext对象
    sc.stop()
  }
}

在上述示例中，我们首先创建了两个RDD：rdd1和rdd2，分别包含了一些整数元素。然后，我们使用union方法将这两个RDD合并为一个新的RDD：joinedRDD。最后，我们使用foreach方法打印合并后的RDD的内容。

请注意，上述示例中使用的是Apache Spark框架来处理RDD。如果您需要了解更多关于Apache Spark的信息，可以参考腾讯云的Apache Spark产品介绍页面：Apache Spark。