如何用Scala在Spark GraphX中寻找特定节点与其相邻节点的交集

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

val conf = new SparkConf().setAppName("GraphXExample").setMaster("local[*]")
val sc = new SparkContext(conf)

val vertices: RDD[(VertexId, String)] = sc.parallelize(Array(
  (1L, "A"), (2L, "B"), (3L, "C"), (4L, "D"), (5L, "E")
))
val edges: RDD[Edge[String]] = sc.parallelize(Array(
  Edge(1L, 2L, "edge1"), Edge(2L, 3L, "edge2"), Edge(3L, 4L, "edge3"), Edge(4L, 5L, "edge4"), Edge(5L, 1L, "edge5")
))
val graph: Graph[String, String] = Graph(vertices, edges)

val targetNode: VertexId = 1L
val neighbors: VertexRDD[Array[VertexId]] = graph.collectNeighborIds(EdgeDirection.Out)

val intersection: Array[VertexId] = neighbors.filter { case (id, _) => id == targetNode }
  .flatMap { case (_, neighborIds) => neighborIds }
  .distinct()
  .collect()