我需要输入火花流输出到Neo4j的图形实时。有没有办法做到这一点。如果是这样,你能分享一些示例代码吗?我见过Mazerunner,但它只将图形数据从Neo4j输入到Spark-Graphx。谢谢。
发布于 2015-06-07 03:43:28
Mazerunner还回写数据。
最简单的方法是使用连接到Neo4j服务器的Neo4j连接器并并发写回数据。Neo4j 2.2+可以承受(相当)高的并发写入负载。
对于scala,可以使用AnormCypher;对于Python,可以使用py2neo。
我目前正在研究Neo4j的spark集成,所以如果你能详细介绍一下你的用例,那将会有很大帮助。例如,你使用的是纯Spark (RDD / DStream)还是GraphX?
https://stackoverflow.com/questions/30685652
复制相似问题