spring-batch - Spring批处理动态提交间隔

Question

我有一个带有平面文件作为项目阅读器的春季批处理应用程序。这个公寓包含两种不同类型的记录。在我的块的定义中，我必须指定一个动态提交间隔。应用程序每次读取新类型的记录时都必须提交。

例子 ：

1, 'recordType1', 50
1, 'recordType1', 51
1, 'recordType1', 52
COMMIT
2, 'recordType2', 'foo'
COMMIT
1, 'recordType1', 53
COMMIT
2, 'recordType2', 'foo'
COMMIT
1, 'recordType1', 50
1, 'recordType1', 50
1, 'recordType1', 50
1, 'recordType1', 50
COMMIT
2, 'recordType2', 'foo'
2, 'recordType2', 'foo'
2, 'recordType2', 'foo'
2, 'recordType2', 'foo'
COMMIT

我怎样才能做到这一点 ？

Answer 1

CompletionPolicy 旨在完全执行此用例。也就是说，您要根据标准提交，而不仅仅是一个固定的数字。看一下

org.springframework.batch.repeat.CompletionPolicy

而不是提交间隔并利用 isComplete 方法来评估记录以及是否应该提交块。