* 構建用戶社交網絡關系。 * 頂點：用戶名、年齡。 * 邊：表示打call（電話）次數。  問題： 1、找出大于30歲的用戶。 2、假設打call超過5次，表示真愛。請找出他（她）們。 ```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 ContactGraphx { def main(args: Array[String]): Unit = { val spark:SparkSession = SparkSession.builder() .master("local[4]") .appName(this.getClass.getName) .getOrCreate() val sc:SparkContext = spark.sparkContext import spark.implicits._ // 1. 構建點集合 val users:RDD[(Long, (String, Int))] = sc.parallelize(Array( (1L, ("Alice", 28)), (2L, ("Bob", 27)), (3L, ("Charlie", 65)), (4L, ("David", 42)), (5L, ("Ed", 55)), (6L, ("Fran", 50)) )) // 2. 構建邊集合 val cntCall:RDD[Edge[Int]] = sc.parallelize(Array( Edge(2L, 1L, 7), Edge(2L, 4L, 2), Edge(3L, 2L, 4), Edge(3L, 6L, 3), Edge(4L, 1L, 1), Edge(5L, 2L, 2), Edge(5L, 3L, 8), Edge(5L, 6L, 3) )) // 3. 構圖 val graph:Graph[(String, Int), Int] = Graph(users, cntCall) // 找出大于30歲的用戶 graph.vertices.filter({case (id, (name, age)) => age > 30}).foreach(x=>println(x.toString())) // 或者 // graph.vertices.filter(_._2._2>30) // (3,(Charlie,65)) // (4,(David,42)) // (5,(Ed,55)) // (6,(Fran,50)) // 假設打call超過5次，表示真愛。請找出他（她）們 graph.triplets.filter(_.attr>5).foreach(x=>println(s"${x.toString()}")) // ((5,(Ed,55)),(3,(Charlie,65)),8) // ((2,(Bob,27)),(1,(Alice,28)),7) } } ```