クラス SimpleChunkProcessor<I,O>
java.lang.ObjectSE
org.springframework.batch.core.step.item.SimpleChunkProcessor<I,O>
- 実装されたすべてのインターフェース:
ChunkProcessor<I>
,org.springframework.beans.factory.InitializingBean
- 既知の直属サブクラス
FaultTolerantChunkProcessor
public class SimpleChunkProcessor<I,O>
extends ObjectSE
implements ChunkProcessor<I>, org.springframework.beans.factory.InitializingBean
基本的なアイテムの書き込みと処理を処理する
ChunkProcessor
インターフェースのシンプルな実装。発生した例外は再スローされます。- 関連事項:
フィールドサマリー
コンストラクターのサマリー
コンストラクター説明SimpleChunkProcessor
(ItemProcessor<? super I, ? extends O> itemProcessor, ItemWriter<? super O> itemWriter) SimpleChunkProcessor
(ItemWriter<? super O> itemWriter) メソッドのサマリー
修飾子と型メソッド説明void
必須プロパティを確認してください。protected final void
doAfterWrite
(Chunk<O> items) リスナーの after write メソッドを呼び出します。protected final void
doOnWriteError
(ExceptionSE e, Chunk<O> items) リスナーの writerError メソッドを呼び出します。protected final O
protected final void
実際の書き込み呼び出しをリスナーコールバックで囲みます。getAdjustedOutputs
(Chunk<I> inputs, Chunk<O> outputs) 入力の追加保存データに基づいて出力を調整するサブクラスの拡張ポイント。protected int
getFilterCount
(Chunk<I> inputs, Chunk<O> outputs) フィルターカウントを計算するためのサブクラスの拡張ポイント。protected MulticasterBatchListener<I,
O> protected void
initializeUserData
(Chunk<I> inputs) 後でアカウンティングの目的で必要になった場合に備えて、サブクラスが入力内容を記憶できるようにするサブクラスの拡張ポイント。protected boolean
isComplete
(Chunk<I> inputs) 入力に追加データを保存するサブクラスの拡張ポイント。final void
process
(StepContribution contribution, Chunk<I> inputs) void
registerListener
(StepListener listener) プロセスの適切な段階でコールバックのリスナーを登録します。void
setItemProcessor
(ItemProcessor<? super I, ? extends O> itemProcessor) void
setItemWriter
(ItemWriter<? super O> itemWriter) void
setListeners
(ListSE<? extends StepListener> listeners) いくつかのStepListener
をハンドラーに登録します。void
setMeterRegistry
(io.micrometer.core.instrument.MeterRegistry meterRegistry) メトリクスに使用するメーターレジストリを設定します。protected void
stopTimer
(io.micrometer.core.instrument.Timer.Sample sample, StepExecution stepExecution, StringSE metricName, StringSE status, StringSE description) transform
(StepContribution contribution, Chunk<I> inputs) protected void
単純な実装はdoWrite(Chunk)
メソッドに委譲し、コントリビューションの書き込みカウントをインクリメントします。protected void
writeItems
(Chunk<O> items)
フィールドの詳細
meterRegistry
protected io.micrometer.core.instrument.MeterRegistry meterRegistry
コンストラクターの詳細
SimpleChunkProcessor
public SimpleChunkProcessor(@Nullable ItemProcessor<? super I, ? extends O> itemProcessor, ItemWriter<? super O> itemWriter) SimpleChunkProcessor
メソッドの詳細
setItemProcessor
- パラメーター:
itemProcessor
- 設定するItemProcessor
setItemWriter
- パラメーター:
itemWriter
- 設定するItemWriter
setMeterRegistry
public void setMeterRegistry(io.micrometer.core.instrument.MeterRegistry meterRegistry) メトリクスに使用するメーターレジストリを設定します。- パラメーター:
meterRegistry
- メーター登録- 導入:
- 5.0
afterPropertiesSet
必須プロパティを確認してください。- 次で指定:
- インターフェース
org.springframework.beans.factory.InitializingBean
のafterPropertiesSet
- 例外:
ExceptionSE
- 関連事項:
InitializingBean.afterPropertiesSet()
setListeners
いくつかのStepListener
をハンドラーに登録します。それぞれが正しい段階で指定された順序でコールバックを取得します。- パラメーター:
listeners
-StepListener
インスタンスのリスト。
registerListener
プロセスの適切な段階でコールバックのリスナーを登録します。- パラメーター:
listener
-StepListener
getListener
- 戻り値:
- リスナー
doProcess
- パラメーター:
item
- 入力項目- 戻り値:
- 処理の結果
- 例外:
ExceptionSE
- エラーが発生した場合にスローされます。
doWrite
実際の書き込み呼び出しをリスナーコールバックで囲みます。- パラメーター:
items
- 書き込まれるアイテムのリスト。- 例外:
ExceptionSE
- エラーが発生した場合にスローされます。
doAfterWrite
リスナーの after write メソッドを呼び出します。- パラメーター:
items
- 書き込まれたばかりのアイテムのリスト。
doOnWriteError
リスナーの writerError メソッドを呼び出します。- パラメーター:
e
- 発生した例外。items
- 書き込みに失敗したアイテムのリスト。
writeItems
- パラメーター:
items
- 書き込まれるアイテムのリスト。- 例外:
ExceptionSE
- エラーが発生した場合にスローされます。
process
- 次で指定:
- インターフェース
ChunkProcessor<I>
のprocess
- 例外:
ExceptionSE
initializeUserData
後でアカウンティングの目的で必要になった場合に備えて、サブクラスが入力内容を記憶できるようにするサブクラスの拡張ポイント。デフォルトの実装では、入力の元のサイズを記憶するためにいくつかのユーザーデータを設定します。このメソッドがオーバーライドされた場合、ユーザーデータが一貫して処理されるように、isComplete(Chunk)
、getFilterCount(Chunk, Chunk)
、getAdjustedOutputs(Chunk, Chunk)
の一部またはすべても必要になる場合があります。- パラメーター:
inputs
- プロセスへの入力
getFilterCount
フィルター数を計算するためのサブクラスの拡張ポイント。デフォルトは、入力サイズと出力サイズの差です。- パラメーター:
inputs
- 変換後の入力outputs
- 変換後の出力- 戻り値:
- サイズの違い
- 関連事項:
isComplete
入力に追加のデータを格納するサブクラスの拡張ポイント。デフォルトでは、入力が空かどうかをチェックするだけです。- パラメーター:
inputs
- 入力チャンク- 戻り値:
- 空の場合は true
- 関連事項:
getAdjustedOutputs
入力に保存された追加データに基づいて出力を調整するサブクラスの拡張ポイント。デフォルトの実装では、出力は変更されずに返されます。- パラメーター:
inputs
- 変換の入力outputs
- 変換の結果- 戻り値:
- 出力は変更されません
- 関連事項:
write
protected void write(StepContribution contribution, Chunk<I> inputs, Chunk<O> outputs) throws ExceptionSE 単純な実装では、doWrite(Chunk)
メソッドに委譲し、コントリビューションの書き込みカウントをインクリメントします。サブクラスは、フォールトトレランスなど、より複雑なシナリオを処理できます。出力項目がスキップされた場合は、入力からも削除する必要があります。- パラメーター:
contribution
- 現在のステップの貢献inputs
- 出力を生じさせた入力outputs
- 書き込む出力- 例外:
ExceptionSE
- 問題がある場合
transform
- 例外:
ExceptionSE
stopTimer
protected void stopTimer(io.micrometer.core.instrument.Timer.Sample sample, StepExecution stepExecution, StringSE metricName, StringSE status, StringSE description)