CODEWITHSUNDEEP
neo4japache-sparkspark-streaming
Narendra Reddy Sanikommu
Narendra Reddy Sanikommu

Reputation: 457

spark streaming to neo4j

I need to input Spark Streaming output to Neo4j as a graph in real time. Is there any way to do that. If so, can you share some example code?. I have seen Mazerunner, but it only inputs graph data from Neo4j to Spark-Graphx. Thank you.

Upvotes: 1

Views: 677

Answers (1)

Michael Hunger
Michael Hunger

Reputation: 41686

Mazerunner also writes data back.

Easiest would be to use a Neo4j connector to Neo4j server and write data back concurrently. Neo4j 2.2+ can sustain (quite) high concurrent write load.

For scala you can use AnormCypher and for Python py2neo

I'm currently looking into spark integration for Neo4j, so it would help a lot if you could detail your use-case a bit. E.g. do you use plain Spark (RDD / DStream) or GraphX?

Upvotes: 2

Related Questions