使用流的自定义操作 API

Question

我正在 java 中实现一个批处理程序。流程如下：我从数据库中获取数据，将数据转换为自定义对象，然后将这些对象放入队列中。然后目标是 运行 之后的一些分析逻辑（例如 nlp）。我的一个朋友告诉我，我应该考虑使用 java 流 api，因为它支持并行处理。我对 Java 8 比较陌生，所以我的问题是在哪里放置（或执行）提到的分析逻辑？有没有办法创建自定义操作，或者我是否必须实现自定义收集器？

提前致谢。

Answer 1

正如@MarkoTopolnik 在评论中提到的 map 是解决方案。