2016-04-27 50 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