2016-04-27 53 views
2

如果我有一个来自cassandra查询的较大结果集。Akka流源 - cassandra结果集

有没有办法让这个结果集成为Akka-Stream的来源,这样我可以处理每一行?

感谢

+0

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

+0

@GiovanniCaporaletti有一个如何使用phanthom做到这一点的例子吗? – Ciaran0

+0

在某些github回购站中有一些示例,如下所示:https://github.com/Tecsisa/reactive-cassandra-phantom (小贴士:您可以在源中封装反应流发布者)。对不起,我不能做出正确的例子,但我很忙 –

回答

4

可能是一个迟到的回答,但肯定的,有一个新的项目alpakka。 Cassandra查询可以作为一个行流提供。看看this documentation