パッケージ org.springframework.batch.core.step.tasklet

クラス TaskletStep

java.lang.ObjectSE
org.springframework.batch.core.step.AbstractStep
org.springframework.batch.core.step.tasklet.TaskletStep
実装されたすべてのインターフェース:
Step、org.springframework.beans.factory.Aware、org.springframework.beans.factory.BeanNameAware、org.springframework.beans.factory.InitializingBean
public class TaskletStep extends AbstractStep
Tasklet への呼び出しとしてステップを実行する単純な実装。おそらく繰り返され、各呼び出しはトランザクションで囲まれています。構造は、ループ内にトランザクション境界を持つループの構造です。ループは、ステップ演算（setStepOperations(RepeatOperations)）によって制御されます。

クライアントは、ステップ操作でインターセプターを使用して、ステップ全体で反復をインターセプトまたはリッスンすることができます。たとえば、ステップが完了したときにコールバックを取得できます。個々のタスクのレベルでコールバックが必要な場合は、チャンク操作のインターセプターを指定できます。
作成者:
Dave Syer, Lucas Ward, Ben Hale, Robert Kasanicky, Michael Minella, Will Schipp, Mahmoud Ben Hassine

  • フィールドの詳細

  • コンストラクターの詳細

    • TaskletStep

      public TaskletStep()
      デフォルトコンストラクター。

    • TaskletStep

      public TaskletStep(StringSE name)
      パラメーター:
      name - TaskletStep の名前

  • メソッドの詳細

    • afterPropertiesSet

      public void afterPropertiesSet() throws ExceptionSE
      次で指定:
      インターフェース org.springframework.beans.factory.InitializingBean の afterPropertiesSet 
      オーバーライド:
      クラス AbstractStep の afterPropertiesSet 
      例外:
      ExceptionSE

    • setTransactionManager

      public void setTransactionManager(org.springframework.transaction.PlatformTransactionManager transactionManager)
      PlatformTransactionManager の公開 setter。
      パラメーター:
      transactionManager - 設定するトランザクションマネージャー

    • setTransactionAttribute

      public void setTransactionAttribute(org.springframework.transaction.interceptor.TransactionAttribute transactionAttribute)
      TransactionAttribute の公開 setter。
      パラメーター:
      transactionAttribute - 設定する TransactionAttribute 

    • setTasklet

      public void setTasklet(Tasklet tasklet)
      Tasklet のパブリック setter。
      パラメーター:
      tasklet - 設定する Tasklet

    • registerChunkListener

      public void registerChunkListener(ChunkListener listener)
      ステップ実行の適切な段階でコールバックのチャンクリスナーを登録します。
      パラメーター:
      listener - ChunkListener

    • setChunkListeners

      public void setChunkListeners(ChunkListener[] listeners)
      各オブジェクトをリスナーとして登録します。
      パラメーター:
      listeners - 既知の型のリスナーオブジェクトの配列。

    • setStreams

      public void setStreams(ItemStream[] streams)
      ステップの適切なタイミングで、コールバック用の各ストリームを登録します。ItemReader と ItemWriter は自動的に登録されますが、ここで登録しても問題ありません。リーダーとライターの注入された依存関係は自動的に登録されないため、それ自体が ItemStream である別のオブジェクトへの委譲を使用して ItemWriter を実装する場合は、ここで委譲を登録する必要があります。
      パラメーター:
      streams - ItemStream オブジェクトの配列。

    • registerStream

      public void registerStream(ItemStream stream)
      ストリームインターフェースへのコールバック用に単一の ItemStream を登録します。
      パラメーター:
      stream - ItemStream のインスタンス

    • setStepOperations

      public void setStepOperations(RepeatOperations stepOperations)
      バッチ処理の外側のループに使用する RepeatOperations。発信者がファクトリを通じて設定する必要があります。デフォルトはプレーン RepeatTemplate です。
      パラメーター:
      stepOperations - RepeatOperations インスタンス。

    • setInterruptionPolicy

      public void setInterruptionPolicy(StepInterruptionPolicy interruptionPolicy)
      StepInterruptionPolicy の Setter。このポリシーは、ジョブの実行を中断するために外部リクエストが行われたかどうかを確認するために使用されます。
      パラメーター:
      interruptionPolicy - StepInterruptionPolicy

    • doExecute

      protected void doExecute(StepExecution stepExecution) throws ExceptionSE
      ステップを処理し、そのコンテキストを更新して、呼び出し側が進行状況を監視できるようにします。ステップはチャンクに分割され、それぞれがトランザクションで実行されます。ステップとその実行および実行コンテキストには、すべて最新の BatchStatus が与えられ、JobRepository は結果を格納するために使用されます。ステップの実行を管理する現在のコンテキストには、さまざまなレポート情報も追加されます。これらの情報は通常、ステップの ExecutionContext を介して呼び出し元が利用できます。
      次で指定:
      クラス AbstractStep の doExecute 
      パラメーター:
      stepExecution - 現在のステップのコンテキスト
      例外:
      JobInterruptedException - ステップまたはチャンクが中断された場合
      RuntimeExceptionSE - チャンクの実行中に例外が発生した場合
      ExceptionSE - 実装によってスローされたチェック済み例外

    • createSemaphore

      protected SemaphoreSE createSemaphore()
      ロックの動作を操作してさまざまな病理をシミュレートできるように、主にテスト目的の拡張ポイント。
      戻り値:
      JobRepository へのアクセスをロックするためのセマフォ

    • close

      protected void close(ExecutionContext ctx) throws ExceptionSE
      クラスからコピーされた説明: AbstractStep
      リソースを閉じるか解放するために、ステップの最後（finally ブロックの最後）でコラボレーターにコールバックを提供するサブクラスの拡張ポイント。デフォルトでは何もしません。
      オーバーライド:
      クラス AbstractStep の close 
      パラメーター:
      ctx - 使用する ExecutionContext
      例外:
      ExceptionSE - 実装によってスローされたチェック済み例外

    • open

      protected void open(ExecutionContext ctx) throws ExceptionSE
      クラスからコピーされた説明: AbstractStep
      ステップを開始するときにサブクラスがコラボレーターにコールバックを提供し、リソースを開いたり取得したりするための拡張ポイント。デフォルトでは何もしません。
      オーバーライド:
      クラス AbstractStep の open 
      パラメーター:
      ctx - 使用する ExecutionContext
      例外:
      ExceptionSE - 実装によってスローされたチェック済み例外

    • getTasklet

      public Tasklet getTasklet()
      タスクレットを取得する -JobOperator のヘルパーメソッド
      戻り値:
      このステップ内で実行されている Tasklet インスタンス