Alpakka Cassandra流量使用

Question

我正在阅读Alpakka Cassandra 这里的文档

它使它非常容易使用卡桑德拉作为一个来源和一个水槽。但是流量的使用呢。

所谓流量使用，我的意思是，我没有使用卡桑德拉作为源或水槽。但要查数据。

用Alpakka有可能吗？或者我应该自己在流中编写Cassandra jdbc代码吗？

Answer 1

1) Sink.如果您检查Alpakka的源代码，您会发现Sink的构造如下

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())

您只需要公开番石榴期货转换器，这是目前包私有阿尔帕卡。

2)源代码。--您始终可以通过执行.flatMapConcat(x => CassandraSource(...)从Source获得Flow )