使用 Java 在 GraphFrames 中获取最短路径

Question

我是 Spark 和 GraphFrames 的新手。

当我想了解 GraphFrame 中的 shortestPaths 方法时，GraphFrames documentation 给了我一个 Scala 中的示例代码，但 Java 中没有。

在他们的文档中，他们提供了以下（Scala 代码）：

import org.graphframes.{examples,GraphFrame}
val g: GraphFrame = examples.Graphs.friends  // get example graph

val results = g.shortestPaths.landmarks(Seq("a", "d")).run()
results.select("id", "distances").show()

在 Java 中，我试过：

import org.graphframes.GraphFrames;
import scala.collection.Seq;
import scala.collection.JavaConverters;

GraphFrame g = new GraphFrame(...,...);
Seq landmarkSeq = JavaConverters.collectionAsScalaIterableConverter(Arrays.asList((Object)"a",(Object)"d")).asScala().toSeq();
g.shortestPaths().landmarks(landmarkSeq).run().show();

或

g.shortestPaths().landmarks(new ArrayList<Object>(List.of((Object)"a",(Object)"d"))).run().show();

转换为 java.lang.Object 是必要的，因为 API 需要 Seq

Answer 1

这似乎是 GraphFrames 0.8.0 中的错误。

参见 github.com

中的 Issue #367

使用 Java 在 GraphFrames 中获取最短路径

Getting shortestPaths in GraphFrames with Java

java

apache-spark

graphframes