我尝试使用 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()
可以在写入函数中调用算法吗?