連通分量是一個子圖，其中任何兩個頂點通過一條邊或一系列邊相互連接，其頂點是原始圖頂點集的子集，其邊是原始圖邊集的子集。  ```scala import org.apache.spark.SparkContext import org.apache.spark.graphx.{Edge, Graph} import org.apache.spark.rdd.RDD import org.apache.spark.sql.SparkSession object ConnectComponts { def main(args: Array[String]): Unit = { val spark: SparkSession = SparkSession.builder() .appName(this.getClass.getName) .master("local[4]") .getOrCreate() val sc: SparkContext = spark.sparkContext // 構建用戶的點集合 val users: RDD[(Long, Int)] = sc.parallelize(Array( (1L, 1), (2L, 2), (3L, 3), (4L, 4), (5L, 5), (6L, 6) )) // 構建用戶的邊集合，頂點6L被孤立，沒有關于它的邊 val cntCall: RDD[Edge[Int]] = sc.parallelize(Array( Edge(1L, 2L, 1), Edge(2L, 3L, 1), Edge(3L, 4L, 1), Edge(4L, 5L, 1), Edge(5L, 1L, 1) )) // 通過頂點和邊構建圖形 val graph = Graph(users, cntCall) // 通過調用API獲取連通分量 graph.connectedComponents().triplets.foreach(println) // 沒有頂點6L // ((3,1),(4,1),1) // ((4,1),(5,1),1) // ((2,1),(3,1),1) // ((1,1),(2,1),1) // ((5,1),(1,1),1) } } ```