我正在尝试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()