欢迎您访问程序员文章站本站旨在为大家提供分享程序员计算机编程知识!
您现在的位置是: 首页

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,就会忽略这条记录
相关标签: spring spring batch