Alpakkaカサンドラ・フローの使用

Question

は、私はそれはそれは非常に簡単で、ソースとシンクとしてカサンドラを使用できるようになりAlpakkaカサンドラhere

のドキュメントを読んでいます。しかし、フローの使用はどうでしょうか。

私が意味するのは、カッサンドラをソースまたはシンクとして使用していないことです。データを参照することになります。

Alpakkaを使用すると可能ですか？または自分自身でCassandra jdbcコードを記述する必要がありますか？

Answer 1

1）シンク。あなたはAlpakkaのsource codeをチェックすると、あなたは

Flow[T] 
     .mapAsyncUnordered(parallelism)(t ⇒ session.executeAsync(statementBinder(t, statement)).asScala()) 
     .toMat(Sink.ignore)(Keep.right) 

あなたが唯一の通過フローが必要な場合、あなたは常にSink.ignore一部をトリミングすることができ、あなたが

があるでしょうし、次のようにシンクが構成されていることがわかります

Flow[T] 
      .mapAsyncUnordered(parallelism)(t ⇒ session.executeAsync(statementBinder(t, statement)).asScala()) 

現在、AlpakkaにパッケージされているGuava先物コンバータを公開する必要があります。

2）ソース。SourceからいつでもFlowを得ることができます。.flatMapConcat(x => CassandraSource(...)