2016-04-27 8 views
2

Wenn ich eine große Ergebnismenge von einer Cassandra-Abfrage habe.Akka Stream Quelle - Cassandra Resultset

Gibt es eine Möglichkeit, dieses Ergebnis als Quelle eines Akka-Streams festzulegen, damit ich jede Zeile verarbeiten kann?

Dank

+0

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

+0

@GiovanniCaporaletti spricht, ist es ein Beispiel dafür, wie es mit phanthom zu tun? – Ciaran0

+0

Es gibt Beispiele in einigen GitHub-Repos, wie folgt: https://github.com/Tecsisa/reactive-cassand-phaphom (Tipp: Sie können einen reaktiven Streams-Publisher in eine Quelle einbinden). Tut mir leid, ich kann kein richtiges Beispiel machen, aber ich bin ziemlich beschäftigt –

Antwort

4

Wahrscheinlich eine späte Antwort, aber ja, gibt es ein neues Projekt alpakka. Die Cassandra-Abfrage kann als Zeilenstrom bereitgestellt werden. Werfen Sie einen Blick auf this documentation.

Verwandte Themen