public class RemotePartitioningWorkerStepBuilder extends StepBuilder
IntegrationFlow
を作成します。StepExecutionRequest
をリッスンします StepExecutionRequestHandler
を呼び出して、受信リクエストごとにワーカーステップを実行します。ワーカーステップは、提供された StepLocator
を使用して見つけられます。StepLocator
が提供されない場合、現在の BeanFactory
で構成された BeanFactoryStepLocator
が使用されますNullChannel
が使用されます (マスター側がワーカーステータスのジョブリポジトリをポーリングするように設定されていると想定)StepBuilderHelper.CommonStepProperties
properties
コンストラクターと説明 |
---|
RemotePartitioningWorkerStepBuilder(java.lang.String name) 指定された名前のステップのステップビルダーを初期化します。 |
修飾子と型 | メソッドと説明 |
---|---|
RemotePartitioningWorkerStepBuilder | allowStartIfComplete(boolean allowStartIfComplete) |
RemotePartitioningWorkerStepBuilder | beanFactory(org.springframework.beans.factory.BeanFactory beanFactory) Bean ファクトリを設定します。 |
<I,O> SimpleStepBuilder<I,O> | chunk(CompletionPolicy completionPolicy) 提供された完了ポリシーを使用して、チャンクでアイテムを処理するステップを作成します。 |
<I,O> SimpleStepBuilder<I,O> | chunk(int chunkSize) 指定されたサイズのチャンクでアイテムを処理するステップを構築します。 |
FlowStepBuilder | flow(Flow flow) フローを実行する新しいステップビルダーを作成します。 |
RemotePartitioningWorkerStepBuilder | inputChannel(org.springframework.messaging.MessageChannel inputChannel) マスターから送信されたステップ実行リクエストを受信する入力チャネルを設定します。 |
JobStepBuilder | job(Job job) ジョブを実行する新しいステップビルダーを作成します。 |
RemotePartitioningWorkerStepBuilder | jobExplorer(JobExplorer jobExplorer) Job Explorer を設定します。 |
RemotePartitioningWorkerStepBuilder | listener(java.lang.Object listener) アノテーションベースのリスナー構成を使用してオブジェクトを登録します。 |
RemotePartitioningWorkerStepBuilder | listener(StepExecutionListener listener) |
RemotePartitioningWorkerStepBuilder | outputChannel(org.springframework.messaging.MessageChannel outputChannel) 応答がマスターステップに送信される出力チャネルを設定します。 |
PartitionStepBuilder | partitioner(Step step) リモート(またはローカル)ステップ用のパーティションステップビルダーを作成します。 |
PartitionStepBuilder | partitioner(java.lang.String stepName, Partitioner partitioner) リモート(またはローカル)ステップ用のパーティションステップビルダーを作成します。 |
RemotePartitioningWorkerStepBuilder | repository(JobRepository jobRepository) |
RemotePartitioningWorkerStepBuilder | startLimit(int startLimit) |
RemotePartitioningWorkerStepBuilder | stepLocator(StepLocator stepLocator) 実行するワーカーステップを見つけるために使用されるステップロケーターを設定します。 |
TaskletStepBuilder | tasklet(Tasklet tasklet) 必ずしもアイテム処理ではなく、カスタムタスクレットでステップを作成します。 |
RemotePartitioningWorkerStepBuilder | transactionManager(org.springframework.transaction.PlatformTransactionManager transactionManager) |
enhance, getJobRepository, getName, getTransactionManager, isAllowStartIfComplete
public RemotePartitioningWorkerStepBuilder(java.lang.String name)
name
- ステップの名前 public RemotePartitioningWorkerStepBuilder inputChannel(org.springframework.messaging.MessageChannel inputChannel)
inputChannel
- 入力チャンネル public RemotePartitioningWorkerStepBuilder outputChannel(org.springframework.messaging.MessageChannel outputChannel)
outputChannel
- 入力チャンネル public RemotePartitioningWorkerStepBuilder jobExplorer(JobExplorer jobExplorer)
jobExplorer
- 使用する求職者 public RemotePartitioningWorkerStepBuilder stepLocator(StepLocator stepLocator)
stepLocator
- 使用するステップロケーター public RemotePartitioningWorkerStepBuilder beanFactory(org.springframework.beans.factory.BeanFactory beanFactory)
beanFactory
- Bean ファクトリ public RemotePartitioningWorkerStepBuilder repository(JobRepository jobRepository)
StepBuilderHelper<StepBuilder>
の repository
public RemotePartitioningWorkerStepBuilder transactionManager(org.springframework.transaction.PlatformTransactionManager transactionManager)
StepBuilderHelper<StepBuilder>
の transactionManager
public RemotePartitioningWorkerStepBuilder startLimit(int startLimit)
StepBuilderHelper<StepBuilder>
の startLimit
public RemotePartitioningWorkerStepBuilder listener(java.lang.Object listener)
StepBuilderHelper
StepBuilderHelper<StepBuilder>
の listener
listener
- リスナーアノテーションで設定されたメソッドを持つオブジェクト public RemotePartitioningWorkerStepBuilder listener(StepExecutionListener listener)
StepBuilderHelper<StepBuilder>
の listener
public RemotePartitioningWorkerStepBuilder allowStartIfComplete(boolean allowStartIfComplete)
StepBuilderHelper<StepBuilder>
の allowStartIfComplete
public TaskletStepBuilder tasklet(Tasklet tasklet)
StepBuilder
StepBuilder
の tasklet
tasklet
- タスクレット TaskletStepBuilder
public <I,O> SimpleStepBuilder<I,O> chunk(int chunkSize)
StepBuilder
SimpleStepBuilder.faultTolerant()
メソッドを呼び出します。ほとんどの場合、このメソッドの呼び出しをパラメーター化して、リーダーとライターの型の安全性を維持する必要があります。new StepBuilder("step1").<Order, Ledger> chunk(100).reader(new OrderReader()).writer(new LedgerWriter()) // ... etc.
StepBuilder
の chunk
I
- 入力として処理されるアイテムの型 O
- 出力する項目の種類 chunkSize
- チャンクサイズ (コミット間隔)SimpleStepBuilder
public <I,O> SimpleStepBuilder<I,O> chunk(CompletionPolicy completionPolicy)
StepBuilder
SimpleStepBuilder.faultTolerant()
メソッドを呼び出します。ほとんどの場合、このメソッドの呼び出しをパラメーター化して、リーダーとライターの型の安全性を維持する必要があります。new StepBuilder("step1").<Order, Ledger> chunk(100).reader(new OrderReader()).writer(new LedgerWriter()) // ... etc.
StepBuilder
の chunk
I
- 入力として処理されるアイテムの型 O
- 出力するアイテムの型 *completionPolicy
- チャンク処理を制御するために使用する完了ポリシー SimpleStepBuilder
public PartitionStepBuilder partitioner(java.lang.String stepName, Partitioner partitioner)
StepBuilder
StepBuilder
の partitioner
stepName
- リモートまたはデリゲートステップの名前 partitioner
- 新しいステップ実行を構築するために使用されるパーティショナー PartitionStepBuilder
public PartitionStepBuilder partitioner(Step step)
StepBuilder
StepBuilder
の partitioner
step
- 並行して実行するステップ public JobStepBuilder job(Job job)
StepBuilder
StepBuilder
の job
job
- 実行するジョブ JobStepBuilder
public FlowStepBuilder flow(Flow flow)
StepBuilder
StepBuilder
の flow
flow
- 実行するフロー FlowStepBuilder