请提供有效的 WRITE 查询

问题描述 投票:0回答:0

我尝试使用 Neo4j 连接器在 Spark 中运行最小生成树算法。但是当我尝试调用它时出现错误:请提供有效的 WRITE 查询。 我的代码如下所示:

val df = (1 to 10)/*...*/.toDF()
df.write
  .format("org.neo4j.spark.DataSource")
  .option("url", "bolt://localhost:7687")
  .option("query", "CALL gds.alpha.spanningTree.minimum.write('graph', {  startNodeId: id(1), relationshipWeightProperty: 'cost'," +
        "  writeProperty: 'CONNECT',weightWriteProperty: 'writeCost'})")
  .save()

可以在写入函数中调用算法吗?

scala apache-spark neo4j minimum-spanning-tree
© www.soinside.com 2019 - 2024. All rights reserved.