spark-graphx

1熱度

1回答

我想知道我可以使用不同類型的頂點對GraphX圖進行建模嗎？假設我有以下實體：產品，買方，賣方。我想用這些實體形成一個圖結構作爲頂點。（例如：以圖形方式顯示由賣家出售並由買家購買的產品。）使用GraphX可以嗎？如果可以，如何？謝謝！

0熱度

1回答

Spark Scala GraphX：InDegrees不返回indengree的節點

我已經在網上搜索了GraphX中圖表字段inDegrees的例子，他們都說它返回圖中每個頂點的不一致。然而，當我做下面的例子： val a = sc.parallelize(List(Edge(1L, 2L, 3L))) val g = Graph.fromEdges[Long, Long](a, 0) g.numVertices g.inDegrees.take(5).foreach(pr

2熱度

1回答

如何使用Spark圖形函數遮罩？

我想檢查一個新圖（稱爲A）是否是其他圖（稱爲B）的子圖。我寫了一個測試的小演示，但失敗了！我跑只是火花外殼演示，火花版本1.6.1： // Build the GraphB val usersB = sc.parallelize(Array( (3L, ("rxin", "student")), (7L, ("jgonzal","postdoc")), (5L, ("

0熱度

1回答

如何將Scala中的數組[VertexIds]轉換爲Map？

在Scala中，我有一個VertexIds v: Array[org.apache.spark.graphx.VertexId] = Array(-2634311911308936962, 2326575714372975825, ...) 的數組，我想轉換成地圖， Map(-2634311911308936962 -> 0, 2326575714372975825 -> 1,

0熱度

1回答

GraphX - 從路徑中檢索所有節點

在GraphX中，是否有一種方法可以檢索某個路徑上的所有節點和圓弧，這些節點和圓弧的長度是一定的？更具體：我想獲得從A到B的所有10個步驟路徑。對於每條路徑，我想獲得節點和弧的列表。感謝

0熱度

1回答

澄清Graphx中的activeDirection用於在無向圖上計算

我需要使用Graphx Pregel API在無向圖上運行計算。如果我設置 activeDirection = EdgeDirection，它會忽略圖的方向性嗎？

4熱度

1回答

Spark中的「錯誤：類型不匹配」，找到和需要的數據類型相同

我正在使用spark-shell來運行我的代碼。在我的代碼中，我定義了一個函數，並使用它的參數調用該函數。問題是我調用該函數時出現以下錯誤。 error: type mismatch; found : org.apache.spark.graphx.Graph[VertexProperty(in class $iwC)(in class $iwC)(in class $iwC)(in cla

0熱度

1回答

使用graphx構建的圖形沒有得到正確的廣播

我使用graphx創建了一個圖形，現在我需要從原始圖形中提取子圖形。 users_graph是具有索引給用戶的子圖的RDD。問題是這些子圖沒有被計算出來。當我試圖對這些子圖進行操作時，我得到一個java.lang.NullPointerException異常。 class VertexProperty(val id:Long) extends Serializable case class Us

0熱度

1回答

如何拼合依賴關係圖？

我是Apache Spark的新手，我可以得到如何爲依賴圖實現「展平」的片段嗎？即可以說我有：節點：A，B，C 邊緣：（A，B），（B，C）這將導致一個新的圖表：節點：A，B，C 邊：（A，B）（A，C）（B，C）

0熱度

1回答

GraphX中Pregel API中的頂點程序和合並消息部分之間的區別

我是GraphX的新手，我不理解Pregel API中的頂點程序和合並消息部分。不要做同樣的事情嗎？例如，從Spark網站獲取的以下Pregel代碼中的Vertex Program和Merge Message部分之間有什麼區別？ import org.apache.spark.graphx._ // Import random graph generation library import