Graphframe 오류가/

Question

내가 Databricks에 스칼라 2.11이 코드 라인을 작성 스파크 :

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 브로 graph_1 = GraphFrame (사용자 edges_1) ^ 노트북 : 15 : 오류 : 안 발견 값 GraphFrame val graph = 그래프 프레임 (graph_1.vertices, edges)

아무도 도와 줄 수 있습니까? 당신이 도서관에서 jar 파일을 가져올 필요하므로 미리 에서

감사는 감사 안토니오

Answer 1

도서관, naitively loded되지 않습니다. 작업 공간 아래에서 파일을 가져올 수 있습니다 (jar 파일을 특별히 가져올 수있는 메시지 상자가 있어야 함). 연결 후 클러스터를 다시 시작해야합니다

에서 jar 파일을 얻을 수 있습니다. graphframes