scala - Spark ストリーミング RDD を Neo4j -Scala にプッシュする

Question

Spark Streaming から Neo4j グラフ データベースへの接続を確立する必要があります。RDD のタイプは ((is,I),(am,Hello)(sam,happy)....) です。Neo4j の単語の各ペアの間にエッジを確立する必要があります。

私が見つけたSpark Streamingのドキュメントで

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.

私はScalaでこれをやっています。私はどうやって行くかについて少し混乱していますか？AnormCypher と Neo4jScala ラッパーを見つけました。これらを使用して作業を完了できますか? もしそうなら、どうすればそれを行うことができますか? そうでない場合、より良い代替手段はありますか？

皆さん、ありがとうございました....

Answer 1

MazeRunner ( http://www.kennybastani.com/2014/11/using-apache-spark-and-neo4j-for-big.html ) を参照すると、いくつかのアイデアが得られます。