我有一个分区作业,它从数据库中读取数据并向数据库中写入数据。我有一个100码的粗码。如果分区失败,并且我希望从上次提交开始重新启动,我是否必须明确指定检查点?(在Serializable checkpointInfo()中?)
如果是,如何/在哪里?
答案
您需要为ItemReader实现这对方法:checkpointInfo()和open()您也可以为ItemWriter)。
示例
你可以在这个答案中看到一个例子。
更多信息
请注意,对于分区步骤,每个分区都有自己的检查点。通过这种方式,从读取器/处理器/写入器的角度来看,编程模型在分区和非分区步骤中非常相似,因此它们可以独立于是否在分区中运行(在大多数情况下)进行编写。