Graphframe錯誤/星火

Question

我寫在斯卡拉2.11這行代碼到Databricks：

import org.graphframes._ 

val user_ridotto = sqlContext.sql("SELECT * FROM userRidotto") 

var users_1 = user_ridotto.select("user_id", "name", "city", "num_fr", 
"fans", "review_count", "importance").withColumnRenamed("user_id", "id") 
val users = users_1.withColumn("ridotto", lit("ridotto")) 
var edges_1 = user_ridotto.select($"user_id" as "src", explode($"friends") 
as 
"dst", lit(1)) 
val graph_1 = GraphFrame(users, edges_1) 
println("users: " + users.count + ", archi_1: " + edges_1.count) 

val paths = graph_1.find("(a)-[e]->(b)") 
.filter("a.ridotto='ridotto'") 
.filter("b.ridotto='ridotto'") 
val edges = paths.select("e.src", "e.dst") 
val graph = GraphFrame(graph_1.vertices, edges) 
println("users: " + users.count + ", archi: " + edges.count) 

但它返回我這些錯誤：

筆記本：1：錯誤：對象graphframes是不是成員包有機的 進口org.graphframes._ ^ 筆記本：8：錯誤：未找到：值GraphFrame VAL graph_1 = GraphFrame（用戶，edges_1） ^ 筆記本：15：錯誤：未找到：值GraphFrame val graph = GraphFrame（graph_1.vertices，edges）

任何人都可以幫助我嗎？

在此先感謝 真誠 安東尼

Answer 1

庫不是naitively loded，所以你需要導入庫下的jar文件。您可以在工作區下導入文件（應該有一個消息框，允許您專門導入jar文件），然後附加它。附加後需要重新啓動集羣

您可以在以下位置獲得jar文件：graphframes