B
- 表現されたビルダーの型 public abstract class AbstractTaskletStepBuilder<B extends AbstractTaskletStepBuilder<B>> extends StepBuilderHelper<AbstractTaskletStepBuilder<B>>
TaskletStep
を構築したいステップビルダーの基本クラス。すべてのタスクレットステップバリアントに共通する関心事を処理します。これは主に、それらが運ぶタスクレットの型に関係しています。StepBuilderHelper.CommonStepProperties
修飾子と型 | フィールドと説明 |
---|---|
protected java.util.Set<ChunkListener> | chunkListeners |
logger, properties
コンストラクターと説明 |
---|
AbstractTaskletStepBuilder(StepBuilderHelper<?> parent) |
修飾子と型 | メソッドと説明 |
---|---|
TaskletStep | build() 流れるような setter によって収集されたコンポーネントからステップを構築します。 |
protected boolean | concurrent() ステップが並行しているかどうかを判断するためのサブクラスの便利なメソッド。 |
protected abstract Tasklet | createTasklet() |
AbstractTaskletStepBuilder<B> | exceptionHandler(ExceptionHandler exceptionHandler) タスクレットが失敗した場合に使用する例外ハンドラーを設定します。 |
protected ExceptionHandler | getExceptionHandler() サブクラスがユーザーによって挿入された例外ハンドラーにアクセスするための便利なメソッド。 |
protected RepeatOperations | getStepOperations() サブクラスがユーザーによって注入されたステップ操作にアクセスするための便利なメソッド。 |
protected java.util.Set<ItemStream> | getStreams() |
protected org.springframework.core.task.TaskExecutor | getTaskExecutor() |
protected int | getThrottleLimit() |
protected org.springframework.transaction.interceptor.TransactionAttribute | getTransactionAttribute() |
AbstractTaskletStepBuilder<B> | listener(ChunkListener listener) チャンクリスナーを登録します。 |
B | listener(java.lang.Object listener) アノテーションベースのリスナー構成を使用してオブジェクトを登録します。 |
protected void | registerStepListenerAsChunkListener() |
AbstractTaskletStepBuilder<B> | stepOperations(RepeatOperations repeatTemplate) タスクレットの実行を繰り返すために使用する繰り返しテンプレートを設定します。 |
AbstractTaskletStepBuilder<B> | stream(ItemStream stream) リスタートデータを管理するコールバックのストリームを登録します。 |
AbstractTaskletStepBuilder<B> | taskExecutor(org.springframework.core.task.TaskExecutor taskExecutor) タスクレットを実行するときに使用するタスクエグゼキュータを提供します。 |
AbstractTaskletStepBuilder<B> | throttleLimit(int throttleLimit) 非同期 taskExecutor(TaskExecutor) の場合、同時タスクレット実行の数を調整できます(スレッドプールによって提供される調整を超えて)。 |
AbstractTaskletStepBuilder<B> | transactionAttribute(org.springframework.transaction.interceptor.TransactionAttribute transactionAttribute) タスクレット実行のトランザクション属性を設定します。 |
allowStartIfComplete, enhance, getJobRepository, getName, getTransactionManager, isAllowStartIfComplete, listener, repository, startLimit, transactionManager
protected java.util.Set<ChunkListener> chunkListeners
public AbstractTaskletStepBuilder(StepBuilderHelper<?> parent)
protected abstract Tasklet createTasklet()
public TaskletStep build()
StepBuilderHelper.enhance(Step)
に、次にサブクラスの createTasklet()
に委譲して、実際のタスクレットを作成します。protected void registerStepListenerAsChunkListener()
public AbstractTaskletStepBuilder<B> listener(ChunkListener listener)
listener
- 登録するリスナー public B listener(java.lang.Object listener)
StepBuilderHelper<AbstractTaskletStepBuilder<B extends AbstractTaskletStepBuilder<B>>>
の listener
listener
- リスナーアノテーションで設定されたメソッドを持つオブジェクト public AbstractTaskletStepBuilder<B> stream(ItemStream stream)
stream
- 登録するストリーム public AbstractTaskletStepBuilder<B> taskExecutor(org.springframework.core.task.TaskExecutor taskExecutor)
taskExecutor
- 登録するタスクエグゼキュータ public AbstractTaskletStepBuilder<B> throttleLimit(int throttleLimit)
taskExecutor(TaskExecutor)
の場合、同時タスクレット実行の数を調整できます(スレッドプールによって提供される調整を超えて)。スロットル制限は、このステップのジョブリポジトリで使用されるデータソースプールサイズよりも小さくする必要があります。throttleLimit
- 許可されるタスクレットの同時実行の最大数 public AbstractTaskletStepBuilder<B> exceptionHandler(ExceptionHandler exceptionHandler)
exceptionHandler
- 例外ハンドラー public AbstractTaskletStepBuilder<B> stepOperations(RepeatOperations repeatTemplate)
repeatTemplate
- 反復のためのルールを持つ繰り返しテンプレート public AbstractTaskletStepBuilder<B> transactionAttribute(org.springframework.transaction.interceptor.TransactionAttribute transactionAttribute)
transactionAttribute
- トランザクション属性セット protected RepeatOperations getStepOperations()
protected ExceptionHandler getExceptionHandler()
protected boolean concurrent()
protected org.springframework.core.task.TaskExecutor getTaskExecutor()
protected int getThrottleLimit()
protected org.springframework.transaction.interceptor.TransactionAttribute getTransactionAttribute()
protected java.util.Set<ItemStream> getStreams()