Akka Streams - 根据某些谓词拆分传入的源数据

Question

我是Akka Streams框架中的新手,我想知道以Akka Streams为目标来解决我的问题的可能性.想象一下这是一个问题:

1. 几个大的iteratee源,例如3-4个大文件,可能具有相同的数据;
2. 需要处理每个文件:解析,转换,计算平均值;
3. 来自文件的数据应该由一些谓词分区,然后由分区处理.从运行到运行,分区谓词可以是动态的;
4. 每个分区都应保存到另一个文件或流中,或者左右.

是否有可能用Akka Streams解决？

Answer 1

你考虑过使用分区吗？