JSR 352. 重新启动分区：如何检查提交？

Question

我有一个从数据库读取和写入的分区作业。我的分块大小为 100。如果分区失败并且我希望从上次提交开始重新启动，我是否必须明确指定检查点？ （在 Serializable checkpointInfo() 中？）

如果是how/where？

Answer 1

回答

您需要为您的 ItemReader[ 实现一对方法：checkpointInfo() 和 open() =27=]（你也可以为你的 ItemWriter）。

例子

您可以在 中查看示例。

更多信息

请注意，对于分区步骤，每个分区都有自己的检查点。通过这种方式，从分区和非分区步骤的 reader/processor/writer 角度来看，编程模型非常相似，因此无论它们是否 运行 在分区中，它们都可以独立编写（对于大多数部分）。