public class TaskletStep extends AbstractStep
Tasklet
への呼び出しとしてステップを実行する単純な実装。おそらく繰り返され、各呼び出しはトランザクションで囲まれています。構造は、ループ内にトランザクション境界を持つループの構造です。ループは、ステップ演算(setStepOperations(RepeatOperations)
)によって制御されます。修飾子と型 | フィールドと説明 |
---|---|
static java.lang.String | TASKLET_TYPE_KEY |
STEP_TYPE_KEY
コンストラクターと説明 |
---|
TaskletStep() デフォルトコンストラクター。 |
TaskletStep(java.lang.String name) |
修飾子と型 | メソッドと説明 |
---|---|
void | afterPropertiesSet() |
protected void | close(ExecutionContext ctx) リソースを閉じるか解放するために、ステップの最後(finally ブロックの最後)でコラボレーターにコールバックを提供するサブクラスの拡張ポイント。 |
protected java.util.concurrent.Semaphore | createSemaphore() ロックの動作を操作してさまざまな病理をシミュレートできるように、主にテスト目的の拡張ポイント。 |
protected void | doExecute(StepExecution stepExecution) ステップを処理し、そのコンテキストを更新して、呼び出し側が進行状況を監視できるようにします。 |
Tasklet | getTasklet() タスクレットを取得する -JobOperator のヘルパーメソッド |
protected void | open(ExecutionContext ctx) ステップを開始するときにサブクラスがコラボレーターにコールバックを提供し、リソースを開いたり取得したりするための拡張ポイント。 |
void | registerChunkListener(ChunkListener listener) ステップ実行の適切な段階でコールバックのチャンクリスナーを登録します。 |
void | registerStream(ItemStream stream) ストリームインターフェースへのコールバック用に単一の ItemStream を登録します。 |
void | setChunkListeners(ChunkListener[] listeners) 各オブジェクトをリスナーとして登録します。 |
void | setInterruptionPolicy(StepInterruptionPolicy interruptionPolicy) StepInterruptionPolicy の Setter。 |
void | setStepOperations(RepeatOperations stepOperations) バッチ処理の外側のループに使用する RepeatOperations 。 |
void | setStreams(ItemStream[] streams) ステップの適切なタイミングで、コールバック用の各ストリームを登録します。 |
void | setTasklet(Tasklet tasklet) Tasklet のパブリック setter。 |
void | setTransactionAttribute(org.springframework.transaction.interceptor.TransactionAttribute transactionAttribute) TransactionAttribute の公開 setter。 |
void | setTransactionManager(org.springframework.transaction.PlatformTransactionManager transactionManager) PlatformTransactionManager の公開 setter。 |
doExecutionRegistration, doExecutionRelease, execute, getCompositeListener, getJobRepository, getName, getStartLimit, isAllowStartIfComplete, registerStepExecutionListener, setAllowStartIfComplete, setBeanName, setJobRepository, setName, setStartLimit, setStepExecutionListeners, toString
public static final java.lang.String TASKLET_TYPE_KEY
public TaskletStep()
public TaskletStep(java.lang.String name)
name
- TaskletStep
の名前 public void afterPropertiesSet() throws java.lang.Exception
org.springframework.beans.factory.InitializingBean
の afterPropertiesSet
AbstractStep
の afterPropertiesSet
java.lang.Exception
public void setTransactionManager(org.springframework.transaction.PlatformTransactionManager transactionManager)
PlatformTransactionManager
の公開 setter。transactionManager
- 設定するトランザクションマネージャー public void setTransactionAttribute(org.springframework.transaction.interceptor.TransactionAttribute transactionAttribute)
TransactionAttribute
の公開 setter。transactionAttribute
- 設定する TransactionAttribute
public void setTasklet(Tasklet tasklet)
Tasklet
のパブリック setter。tasklet
- 設定する Tasklet
public void registerChunkListener(ChunkListener listener)
listener
- ChunkListener
public void setChunkListeners(ChunkListener[] listeners)
listeners
- 既知の型のリスナーオブジェクトの配列。public void setStreams(ItemStream[] streams)
ItemReader
と ItemWriter
は自動的に登録されますが、ここで登録しても問題ありません。リーダーとライターの注入された依存関係は自動的に登録されないため、それ自体が ItemStream
である別のオブジェクトへの委譲を使用して ItemWriter
を実装する場合は、ここで委譲を登録する必要があります。streams
- ItemStream
オブジェクトの配列。public void registerStream(ItemStream stream)
ItemStream
を登録します。stream
- ItemStream
のインスタンス public void setStepOperations(RepeatOperations stepOperations)
RepeatOperations
。発信者がファクトリを通じて設定する必要があります。デフォルトはプレーン RepeatTemplate
です。stepOperations
- RepeatOperations
インスタンス。public void setInterruptionPolicy(StepInterruptionPolicy interruptionPolicy)
StepInterruptionPolicy
の Setter。このポリシーは、ジョブの実行を中断するために外部リクエストが行われたかどうかを確認するために使用されます。interruptionPolicy
- StepInterruptionPolicy
protected void doExecute(StepExecution stepExecution) throws java.lang.Exception
BatchStatus
が与えられ、JobRepository
は結果を格納するために使用されます。ステップの実行を管理する現在のコンテキストには、さまざまなレポート情報も追加されます。これらの情報は通常、ステップの ExecutionContext
を介して呼び出し元が利用できます。AbstractStep
の doExecute
stepExecution
- 現在のステップのコンテキスト JobInterruptedException
- ステップまたはチャンクが中断された場合 java.lang.RuntimeException
- チャンクの実行中に例外が発生した場合 java.lang.Exception
- 実装によってスローされたチェック済み例外 protected java.util.concurrent.Semaphore createSemaphore()
protected void close(ExecutionContext ctx) throws java.lang.Exception
AbstractStep
AbstractStep
の close
ctx
- 使用する ExecutionContext
java.lang.Exception
- 実装によってスローされたチェック済み例外 protected void open(ExecutionContext ctx) throws java.lang.Exception
AbstractStep
AbstractStep
の open
ctx
- 使用する ExecutionContext
java.lang.Exception
- 実装によってスローされたチェック済み例外