我应该如何将这个火花 scala 线翻译成 java



我正在尝试spark-neo4j连接器。在此链接的示例中,我发现了以下行:

neo.cypher("MATCH (n:Person) RETURN id(n)").loadRdd[Long].mean

我正在尝试将此行转换为 Java 等效项。但是由于缺乏对scala的理解,我不知道我应该如何进行。问题出在loadRdd[Long].

我对 Spark 了解不多,但我希望 java 是:

neo.cypher("MATCH (n:Person) RETURN id(n)").<long>loadRdd().mean()

最新更新