0

spark graphframe を使用してグラフを作成しようとしています

コードは次のとおりです。

import org.graphframes._

// Node DataFrames
val v = sqlContext.createDataFrame(List(
  ("a", "Alice", 34),
  ("b", "Bob", 36),
  ("c", "Charlie", 30),
  ("d", "David", 29),
  ("e", "Esther", 32),
  ("f", "Fanny", 36),
  ("g", "Gabby", 60)
)).toDF("id", "name", "age")

// Edge DataFrame
val e = sqlContext.createDataFrame(List(
  ("a", "b", "friend"),
  ("b", "c", "follow"),
  ("c", "b", "follow"),
  ("f", "c", "follow"),
  ("e", "f", "follow"),
  ("e", "d", "friend"),
  ("d", "a", "friend"),
  ("a", "e", "friend")
)).toDF("src", "dst", "relationship")

// Create a GraphFrame
val g = GraphFrame(v, e)

しかし、これは私が得ているエラーです:

エラー: クラス ファイル 'GraphFrame.class' のロード中に検出された欠落または無効な依存関係。パッケージ org.apache.spark のタイプ Logging にアクセスできませんでした。それ (またはその依存関係) が見つからないためです。依存関係の欠落または競合がないか、ビルド定義を確認してください。(問題のあるクラスパスを確認するために で再実行し-Ylog-classpathます。) 「GraphFrame.class」が互換性のないバージョンの org.apache.spark に対してコンパイルされた場合、完全な再構築が役立つ場合があります。

Apache Spark 2.1 と Scala 2.11 を使用しています。何が問題になる可能性がありますか？

4

1 に答える 1