public abstract class CheckpointSupport extends ItemStreamSupport
ExecutionContext
に追加される前にコピーされます。チェックポイントオブジェクトをコピーできず、同じインスタンスにさらに変更が加えられると、副作用が発生する可能性があります。このような場合、リーダー / ライターで処理されているオブジェクトのコピーを ItemReader.checkpointInfo()
または ItemWriter.checkpointInfo()
呼び出しを介して返すことをお勧めします。コンストラクターと説明 |
---|
CheckpointSupport(java.lang.String checkpointKey) |
修飾子と型 | メソッドと説明 |
---|---|
void | close() ノーオペレーション。 |
protected abstract java.io.Serializable | doCheckpoint() バッチ成果物の現在の状態を表す Serializable を提供するために使用されます。 |
protected abstract void | doClose() 基礎となるバッチ成果物を閉じるために使用されます |
protected abstract void | doOpen(java.io.Serializable checkpoint) 以前に保存されたチェックポイント情報でバッチ成果物を開くために使用されます。 |
void | open(ExecutionContext executionContext) ノーオペレーション。 |
void | update(ExecutionContext executionContext) 空の ExecutionContext を返します。 |
getExecutionContextKey, setExecutionContextName, setName
public CheckpointSupport(java.lang.String checkpointKey)
checkpointKey
- チェックポイントオブジェクトを ExecutionContext
に格納するためのキー public void open(ExecutionContext executionContext) throws ItemStreamException
ItemStreamSupport
ItemStream
の open
ItemStreamSupport
の open
executionContext
- 現在のステップの ExecutionContext
再起動時のステップの最後の実行からの executionContext になります。ItemStreamException
ItemStream.open(ExecutionContext)
protected abstract void doOpen(java.io.Serializable checkpoint) throws java.lang.Exception
checkpoint
- 以前に保存されたチェックポイントオブジェクト java.lang.Exception
- 実装によってスローされます public void update(ExecutionContext executionContext) throws ItemStreamException
ItemStreamSupport
ExecutionContext
を返します。ItemStream
の update
ItemStreamSupport
の update
executionContext
- 更新される ItemStreamException
ItemStream.update(ExecutionContext)
protected abstract java.io.Serializable doCheckpoint() throws java.lang.Exception
Serializable
を提供するために使用されます。java.lang.Exception
- 実装によってスローされます public void close() throws ItemStreamException
ItemStreamSupport
ItemStream
の close
ItemStreamSupport
の close
ItemStreamException
ItemStream.close()
protected abstract void doClose() throws java.lang.Exception
java.lang.Exception
- 基礎となる実装によってスローされます