Nhận tất cả các nút kết nối với một nút trong Apache Spark GraphX ​​

Question

Giả sử chúng tôi đã có đầu vào trong Apache GraphX ​​như:

Vertex RDD:

val vertexArray = Array(
    (1L, "Alice"), 
    (2L, "Bob"), 
    (3L, "Charlie"), 
    (4L, "David"), 
    (5L, "Ed"), 
    (6L, "Fran") 
) 

Cạnh RDD:

val edgeArray = Array(
    Edge(1L, 2L, 1), 
    Edge(2L, 3L, 1), 
    Edge(3L, 4L, 1), 
    Edge(5L, 6L, 1) 
) 

Tôi cần tất cả các thành phần được kết nối với một nút trong Apache Spark GraphX ​​

1,[1,2,3,4] 
5,[5,6] 

Answer 1

Bạn có thể sử dụng ConnectedComponents trả về

một đồ thị với giá trị đỉnh chứa id đỉnh thấp nhất trong thành phần kết nối có chứa đỉnh đó.

và định hình lại kết quả

graph.connectedComponents.vertices.map(_.swap).groupByKey