JSR 352. Перезапуск разделов: Как проверить коммит?

Question

У меня есть разделенная работа, которая читает и записывает в БД. У меня размер фрагмента равен 100. Если раздел не работает и я хочу, чтобы перезапуск произошел с момента последнего коммита, нужно ли явно указывать контрольную точку? (в Serializable checkpointInfo()?)

Если да, то как и где?

Answer 1

Ответ

Вам нужно реализовать пару методов: checkpointInfo () и open() для вашего ItemReader (и вы можете также для вашего ItemWriter).

пример

Вы можете увидеть пример в этом ответе.

Больше информации

Обратите внимание, что для разделенного шага каждый раздел имеет свою собственную контрольную точку. Таким образом, модель программирования очень похожа с точки зрения читателя / процессора / записывающего устройства на разделенные и неразделенные этапы, и поэтому они могут быть записаны независимо от того, запущены они в разделе или нет (по большей части).