spring批处理itemWriter仅在获取所有项后写入

Question

我有一个简单的Spring批处理作业，包含几个步骤，最后一步是编写报表，所以我有ItemReader、ItemProcessor和ItemWriter。ItemWriter按块编写取决于步骤中定义的块数，但我需要等到获得所有项后再编写最终报告。我怎么能那样做？

public class ReportItemWriter implements ItemWriter<ReportItem> {
    private List<ReportItem> allItems = Lists.newArrayList();
    ... 

public void write(List<? extends ReportItem> reportItems) throws Exception {
    allItems.addAll(reportItems);
    writeReport(allItems);  <-- here it only write chunk of items to the report
}

Answer 1

如果您的Writer上有@jobscope。您可以使用@predestroy（Spring注释）来实现这一点。您可以使用字段来存储需要写入的所有项。在预销毁功能上，你可以写。

private List<YourItem> items = new ArrayList<>();

@Override
public void write(argument here) {
    items.addAll(YourItem);
}    

@PreDestroy
public void teardown() {
    // do the write for all items
}