Graphframe Fehler in Scala/Funken

Question

ich diese Code-Zeilen in Scala 2.11 in Databricks schrieb:

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) 

aber es gibt mir diese Fehlermeldung:

Notebook: 1: Fehler: Objekt graphframes ist kein Mitglied Paket von org import org.graphframes._ ^ Notebook: 8: Fehler: nicht gefunden: Wert GraphFrame val graph_1 = GraphFrame (Benutzer, edges_1) ^ Notebook: 15: Fehler: nicht gefunden: Wert GraphFrame val graph = GraphFrame (graph_1.vertices, edges)

könnte mir jemand helfen?

Vielen Dank im Voraus Mit freundlichen Grüßen Antonio

Answer 1

die Bibliothek naitively nicht loded, so dass Sie die JAR-Datei unter Bibliotheken importieren müssen. Sie können die Datei unter Arbeitsbereich importieren (dort sollte ein Meldungsfeld enthalten sein, mit dem Sie JAR-Dateien gezielt importieren können) und anschließend anhängen. Nach dem Anfügen müssen Sie den Cluster neu starten

Sie können die JAR-Datei erhalten unter: graphframes