可以写个demo吗，比如求图中节点编号前10个的点的二跳邻居（图中一共100个点）

好的，我可以为您提供一个简单的代码示例，用于实现求图中节点编号前10个点的二跳邻居。代码如下：

import org.apache.spark.graphx._
import org.apache.spark.rdd.RDD

// 定义节点属性
case class VertexProperty()

// 定义边属性
case class EdgeProperty()

// 定义消息类型
case class Message(vertexId: Long, hops: Int)

object PregelDemo {
  def main(args: Array[String]): Unit = {
    val sc = new SparkContext(...)
    val vertexFile = "path/to/vertex/file"
    val edgeFile = "path/to/edge/file"

    // 读取节点和边的数据
    val vertexRDD: RDD[(VertexId, VertexProperty)] = sc.textFile(vertexFile)
      .map(line => {
        val fields = line.split(" ")
        (fields(0).toLong, VertexProperty())
      })
    val edgeRDD: RDD[Edge[EdgeProperty]] = sc.textFile(edgeFile)
      .map(line => {
        val fields = line.split(" ")
        Edge(fields(0).toLong, fields(1).toLong, EdgeProperty())
      })

    // 构建图
    val graph = Graph(vertexRDD, edgeRDD)

    // 初始化部分节点为激活节点
    val activeNodes: RDD[(VertexId, Int)] = vertexRDD
      .filter(v => v._1 <= 10)
      .map(v => (v._1, 1))

    // 迭代计算二跳邻居
    val result = Pregel(graph.mapVertices((_, _) => List[Long]()), List[Long](), activeNodes)(
      (id, attr, msg) => {
        if (msg.isEmpty) attr // 如果没有收到消息，则不做处理，直接返回节点属性
        else attr ++ msg.map(_.vertexId) // 否则将收到的消息中的节点加入到当前节点的邻居列表中
      },
      triplet => {
        if (triplet.srcAttr.contains(triplet.dstId)) Iterator.empty // 如果当前节点已经被访问过，则不再向下传递消息
        else Iterator((triplet.dstId, Message(triplet.srcId, 1))) // 否则向下传递1跳消息
      },
      (a, b) => a ::: b // 消息的合并操作
    ).vertices.map(v => (v._1, v._2.toSet.filter(_ != v._1).flatMap(graph.getNeighbors(_).map(_.toLong))))

    // 打印结果
    result.collect().foreach(println)

    sc.stop()
  }
}

上述代码中，我们首先读取了节点和边的数据，并构建了一张图。然后，我们通过`activeNodes`变量初始化了前10个节点为激活节点。接着，我们使用Pregel模型进行迭代计算，每次迭代将消息从1跳扩展到2跳，最终得到每个节点的二跳邻居。最后，我们将结果打印出来。