クラス SimpleStepBuilder<I,O>

メソッドの詳細

• faultTolerant

  public FaultTolerantStepBuilder<I,O> faultTolerant()

• build

  public TaskletStep build()

  提供されるリーダー、ライター、プロセッサーでステップを構築します。

  オーバーライド:

  クラス AbstractTaskletStepBuilder<SimpleStepBuilder<I,O>> の build 

  戻り値:

  完全に構成され、実行の準備ができているタスクレットステップ

  関連事項:

  • AbstractTaskletStepBuilder.build()

• registerStepListenerAsItemListener

  protected void registerStepListenerAsItemListener()

• createTasklet

  protected Tasklet createTasklet()

  次で指定:

  クラス AbstractTaskletStepBuilder<SimpleStepBuilder<I,O>> の createTasklet 

• chunk

  public SimpleStepBuilder<I,O> chunk(int chunkSize)

  このステップのチャンクサイズまたはコミット間隔を設定します。これは、1 回のトランザクションで処理が開始される前に読み取られるアイテムの最大数です。completionPolicy とは互換性がありません。

  パラメーター:

  chunkSize - チャンクサイズ (別名コミット間隔)

  戻り値:

  流れるようなチェーン用

• chunk

  public SimpleStepBuilder<I,O> chunk(CompletionPolicy completionPolicy)

  チャンク処理の完了ポリシーを設定します。このポリシーがチャンクが完了したと判断するまでアイテムが読み取られ、chunk size（またはコミット間隔）だけの場合よりも詳細に制御されます。

  パラメーター:

  completionPolicy - チャンクの完了ポリシー

  戻り値:

  流れるようなチェーン用

• reader

  public SimpleStepBuilder<I,O> reader(ItemReader<? extends I> reader)

  アイテムのストリームを提供するアイテムリーダー。対応するインターフェースを実装している場合、AbstractTaskletStepBuilder.stream(ItemStream) またはリスナーとして自動的に登録されます。デフォルトでは非トランザクションと見なされます。

  パラメーター:

  reader - アイテムリーダー

  戻り値:

  流れるようなチェーン用

  関連事項:

  • readerTransactionalQueue

• writer

  public SimpleStepBuilder<I,O> writer(ItemWriter<? super O> writer)

  アイテムのチャンクを書き込むアイテムライター。対応するインターフェースを実装している場合、AbstractTaskletStepBuilder.stream(ItemStream) またはリスナーとして自動的に登録されます。

  パラメーター:

  writer - アイテムライター

  戻り値:

  流れるようなチェーン用

• processor

  public SimpleStepBuilder<I,O> processor(ItemProcessor<? super I,? extends O> processor)

  アイテムのストリームを処理または変換するアイテムプロセッサー。対応するインターフェースを実装している場合、AbstractTaskletStepBuilder.stream(ItemStream) またはリスナーとして自動的に登録されます。

  パラメーター:

  processor - アイテムプロセッサー

  戻り値:

  流れるようなチェーン用

• readerIsTransactionalQueue

  public SimpleStepBuilder<I,O> readerIsTransactionalQueue()

  リーダーがトランザクション対応（通常はキュー）であることを示すフラグを設定します。つまり、失敗したアイテムはロールバックされ、後続のトランザクションで再表示される可能性があります。デフォルトは false です。つまり、アイテムはトランザクションの外部で読み取られ、場合によってはキャッシュされます。

  戻り値:

  流れるようなチェーン用

• listener

  public SimpleStepBuilder<I,O> listener(ObjectSE listener)

  アノテーションベースのリスナー構成を使用してオブジェクトを登録します。

  オーバーライド:

  クラス AbstractTaskletStepBuilder<SimpleStepBuilder<I,O>> の listener 

  パラメーター:

  listener - リスナーアノテーションで設定されたメソッドを持つオブジェクト

  戻り値:

  流れるようなチェーン用

• listener

  public SimpleStepBuilder<I,O> listener(ItemReadListener<? super I> listener)

  アイテムリーダーリスナーを登録します。

  パラメーター:

  listener - 登録するリスナー

  戻り値:

  流れるようなチェーン用

• listener

  public SimpleStepBuilder<I,O> listener(ItemWriteListener<? super O> listener)

  アイテムライターリスナーを登録します。

  パラメーター:

  listener - 登録するリスナー

  戻り値:

  流れるようなチェーン用

• listener

  public SimpleStepBuilder<I,O> listener(ItemProcessListener<? super I,? super O> listener)

  アイテムプロセッサーリスナーを登録します。

  パラメーター:

  listener - 登録するリスナー

  戻り値:

  流れるようなチェーン用

• chunkOperations

  public SimpleStepBuilder<I,O> chunkOperations(RepeatOperations repeatTemplate)

  chunk size または completion policy の代わりに、アイテムリーダーの繰り返しを処理する完全な繰り返し操作インスタンスを提供できます。

  パラメーター:

  repeatTemplate - チャンクの完全な繰り返しテンプレート

  戻り値:

  流れるようなチェーン用

• self

  protected SimpleStepBuilder<I,O> self()

  次で指定:

  クラス StepBuilderHelper<SimpleStepBuilder<I,O>> の self 

• createChunkOperations

  protected RepeatOperations createChunkOperations()

• getReader

  protected ItemReader<? extends I> getReader()

• getWriter

  protected ItemWriter<? super O> getWriter()

• getProcessor

  protected ItemProcessor<? super I,? extends O> getProcessor()

• getChunkSize

  protected int getChunkSize()

• isReaderTransactionalQueue

  protected boolean isReaderTransactionalQueue()

• getItemListeners

  protected SetSE<StepListener> getItemListeners()

• getChunkCompletionPolicy

  protected CompletionPolicy getChunkCompletionPolicy()

  戻り値:

  チャンクサイズおよび挿入されたポリシー（存在する場合）と一致する CompletionPolicy

• registerAsStreamsAndListeners

  protected void registerAsStreamsAndListeners(ItemReader<? extends I> itemReader, ItemProcessor<? super I,? extends O> itemProcessor, ItemWriter<? super O> itemWriter)