Apache Spark/GraphX지도상의 제한

Question

나는 sth를 만들려고 노력하고있다. GraphX의 Pregel 구현과 마찬가지로, mapReduceTriplets -Function을 사용하고 싶지 않습니다. 대신 나는 트리플렛과 꼭지점이 필요하지 않기 때문에 graph.vertices.flatMap을 사용하려고합니다.

while(){ 
    // Create messages for other nodes and run program logic, 
    // should only run on nodes that have received a message on round before 
    messages = graph.vertices.flatMap() 

    // Join back nodes into graph 
    newVerts= graph.innerJoin(messages) 
    g : Graph = graph.outerJoinVertices(newVerts) 
} 

내 문제와 같은

내 코드 해골 모양 (어느 정도는) i 반복에서 난 단지 라운드 i-1에 메시지를받은 노드에 flatMap 작업을 수행 할 것입니다. mapReduceTriplets를 사용하면이 노드 만 활성 상태 인 activeSet을 사용하여 수행되지만 노드 만 사용되는 VertexRDD에 대해서는 이러한 작업을 찾을 수 없습니다.

이 문제를 효율적으로 해결하는 방법에 대한 아이디어가 있습니까?

미리 감사드립니다.

Answer 1

나는 내 마지막으로 그래프의 꼭지점을 사용하고 계산을하고 새 값에 다시 참여할 수 있다는 것을 알았습니다.