Java中的spring流式文件群
我在java
中有一个List<File> folder
,每个文件都需要逐行处理。在spring批处理中,有一个read
函数,它返回需要处理的object
和需要终止批处理的null
。我想使用流来实现这一点。我只能将这些文件映射到一个流。如何使用streams逐行读取文件?此外,每一行在发送到处理器之前都需要使用一些逻辑进行处理
到目前为止我的代码
folder.map((file) -> new CSVReader(new FileReader(file))).map((csv) -> csv.iterator()).
我希望得到一个最终的迭代器,我可以在它上面执行以下操作
public Object read() {
if(iter.hasNext() {
return iter.next();
}
}
共 (0) 个答案