Spring batch 设置processor过滤器来跳过不需要的数据
程序员文章站
2022-05-18 20:45:53
...
在批处理中有些数据可能不符合要求, 哪么怎么剔除这些无效的数据呢?
Spring batch 的整体架构是:
1、读取数据
2、对数据进行各种处理
3、对数据进行写操作
那么我们可以在对数据处理时插入一个过滤的processor,如果当前这条数据不合格,我们就返回null。
定义一个xxxProcessor 类实现 org.springframework.batch.item.ItemProcessor
ItemProcessor接口源码:
public interface ItemProcessor<I, O> {
/**
* Process the provided item, returning a potentially modified or new item for continued
* processing. If the returned result is null, it is assumed that processing of the item
* should not continue.
*
* @param item to be processed
* @return potentially modified or new item for continued processing, null if processing of the
* provided item should not continue.
* @throws Exception
*/
O process(I item) throws Exception;
}
从注释If the returned result is null, it is assumed that processing of the item should not continue. 可以看到,如果返回null,就会忽略这条记录
上一篇: nginx访问白名单配置