2016-04-27 12 views
2

私はcassandraクエリから大きな結果セットを持っています。Akkaストリームソース - cassandra resultset

この結果をAkka-Streamのソースとして設定して、各行を処理できる方法はありますか?

おかげ

+0

https://github.com/outworkers/phantom –

+0

@GiovanniCaporaletti phanthomでそれを行う方法の例がある を話し、このライブラリを使用して終了しましたか? – Ciaran0

+0

いくつかのgithub reposには、https://github.com/Tecsisa/reactive-cassandra-phantom のヒントがあります(ヒント:反応性のあるストリームのパブリッシャーをソースでラップすることができます)。申し訳ありませんが、私は適切な例を作ることはできませんが、私はかなり忙しいです –

答えて

4

おそらく後半の答えが、はい、新しいプロジェクトalpakkaがあります。 Cassandraクエリは、行のストリームとして提供できます。 this documentationをご覧ください。