I need to establish a connection from Spark Streaming to Neo4j graph
database.The RDDs are of type((is,I),(am,Hello)(sam,happy)....). I need to
establish a edge between each pair of words in Neo4j.
In Spark Streaming documentation I found
dstream.foreachRDD { rdd =>
rdd.foreachPartition { partitionOfRecords =>
// ConnectionPool is a static, lazily initialized pool of connections
val connection = ConnectionPool.getConnection()
partitionOfRecords.foreach(record => connection.send(record))
ConnectionPool.returnConnection(connection) // return to the pool for
future reuse
}}
to the push to the data to an external database.
I am doing this in Scala. I am little confused about how to go about? I
found AnormCypher and Neo4jScala wrapper. Can I use these to get work done?
If so, how can I do that? If not, all there any better alternatives?
Thank you all....
--
You received this message because you are subscribed to the Google Groups
"Neo4j" group.
To unsubscribe from this group and stop receiving emails from it, send an email
to [email protected].
For more options, visit https://groups.google.com/d/optout.
