我正在用java实现一个批处理程序。流程如下:从数据库中获取数据,将数据转换为自定义对象,然后将这些对象放入队列中。然后,目标是随后运行一些分析逻辑(例如nlp)。我的一位朋友告诉我,我应该考虑使用java流api,因为它支持并行处理。我对Java 8比较陌生,所以我的问题是在哪里放置(或执行)上述的分析逻辑?是否有创建自定义操作的方法,还是必须实现自定义收集器?
提前谢谢你。
发布于 2015-03-14 14:52:49
正如@MarkoTopolnik的评论中提到的,映射是解决方案。
https://stackoverflow.com/questions/29034575
复制相似问题