我正在用java实现一个批处理程序。流程如下:我从数据库获取数据,将数据转换为自定义对象,然后将这些对象放入队列中。然后目标是随后运行一些分析逻辑(例如 nlp)。我的一个 friend 告诉我我应该考虑使用 java Stream api,因为它支持并行处理。我对 Java 8 比较陌生,所以我的问题是在哪里放置(或执行)提到的分析逻辑?有没有办法创建自定义操作,或者我是否必须实现自定义收集器?
提前谢谢您。
最佳答案
正如 @MarkoTopolnik 的评论中所提到的, map 就是解决方案。
关于java - 使用 Stream API 进行自定义操作,我们在Stack Overflow上找到一个类似的问题: https://stackoverflow.com/questions/29034575/