クラス RemotePartitioningWorkerStepBuilder
java.lang.ObjectSE
org.springframework.batch.core.step.builder.StepBuilderHelper<StepBuilder>
org.springframework.batch.core.step.builder.StepBuilder
org.springframework.batch.integration.partition.RemotePartitioningWorkerStepBuilder
リモートパーティション設定のワーカーステップのビルダー。このビルダーは、以下を行う
IntegrationFlow
を作成します。- 入力チャネルのマネージャーからの
StepExecutionRequest
をリッスンします StepExecutionRequestHandler
を呼び出して、受信リクエストごとにワーカーステップを実行します。ワーカーステップは、提供されたStepLocator
を使用して見つけられます。StepLocator
が提供されない場合、現在のBeanFactory
で構成されたBeanFactoryStepLocator
が使用されます- 出力チャネルでマネージャーに応答します (マネージャーステップが ワーカーからの応答を集約するように構成されている場合)。出力チャンネルが提供されていない場合は、
NullChannel
が使用されます (マネージャー側が ワーカーステータスのジョブリポジトリをポーリングするように構成されていると仮定します)
- 導入:
- 4.1
- 作成者:
- Mahmoud Ben Hassine
ネストされたクラスのサマリー
クラス org.springframework.batch.core.step.builder.StepBuilderHelper から継承されたネストクラス / インターフェース
StepBuilderHelper.CommonStepProperties
フィールドサマリー
クラス org.springframework.batch.core.step.builder.StepBuilderHelper から継承されたフィールド
properties
コンストラクターのサマリー
コンストラクター説明非推奨、削除予定: この API 要素は、将来のバージョンで削除される可能性があります。RemotePartitioningWorkerStepBuilder
(StringSE name, JobRepository jobRepository) 指定された名前のステップのステップビルダーを初期化します。メソッドのサマリー
修飾子と型メソッド説明allowStartIfComplete
(boolean allowStartIfComplete) beanFactory
(org.springframework.beans.factory.BeanFactory beanFactory) Bean ファクトリを設定します。<I,
O> SimpleStepBuilder<I, O> chunk
(int chunkSize) 非推奨、削除予定: この API 要素は、将来のバージョンで削除される可能性があります。<I,
O> SimpleStepBuilder<I, O> chunk
(int chunkSize, org.springframework.transaction.PlatformTransactionManager transactionManager) 指定されたサイズのチャンクでアイテムを処理するステップを構築します。<I,
O> SimpleStepBuilder<I, O> chunk
(CompletionPolicy completionPolicy) 非推奨、削除予定: この API 要素は、将来のバージョンで削除される可能性があります。<I,
O> SimpleStepBuilder<I, O> chunk
(CompletionPolicy completionPolicy, org.springframework.transaction.PlatformTransactionManager transactionManager) 提供された完了ポリシーを使用して、チャンクでアイテムを処理するステップを作成します。フローを実行する新しいステップビルダーを作成します。inputChannel
(org.springframework.messaging.MessageChannel inputChannel) マネージャーから送信されたステップ実行リクエストを受信する入力チャネルを設定します。ジョブを実行する新しいステップビルダーを作成します。jobExplorer
(JobExplorer jobExplorer) Job Explorer を設定します。アノテーションベースのリスナー構成を使用してオブジェクトを登録します。listener
(StepExecutionListener listener) outputChannel
(org.springframework.messaging.MessageChannel outputChannel) 応答がマネージャーステップに送信される出力チャネルを設定します。partitioner
(StringSE stepName, Partitioner partitioner) リモート(またはローカル)ステップ用のパーティションステップビルダーを作成します。partitioner
(Step step) リモート(またはローカル)ステップ用のパーティションステップビルダーを作成します。repository
(JobRepository jobRepository) 非推奨、削除予定: この API 要素は、将来のバージョンで削除される可能性があります。startLimit
(int startLimit) stepLocator
(StepLocator stepLocator) 実行するワーカーステップを見つけるために使用されるステップロケーターを設定します。非推奨、削除予定: この API 要素は、将来のバージョンで削除される可能性があります。tasklet
(Tasklet tasklet, org.springframework.transaction.PlatformTransactionManager transactionManager) 必ずしもアイテム処理ではなく、カスタムタスクレットでステップを作成します。クラス org.springframework.batch.core.step.builder.StepBuilder から継承されたメソッド
self
クラス org.springframework.batch.core.step.builder.StepBuilderHelper から継承されたメソッド
enhance, getJobRepository, getName, isAllowStartIfComplete, meterRegistry, observationConvention, observationRegistry
コンストラクターの詳細
RemotePartitioningWorkerStepBuilder
@DeprecatedSE(since="5.0", forRemoval=true) public RemotePartitioningWorkerStepBuilder(StringSE name) 非推奨、削除予定: この API 要素は、将来のバージョンで削除される可能性があります。指定された名前のステップのステップビルダーを初期化します。- パラメーター:
name
- ステップの名前
RemotePartitioningWorkerStepBuilder
指定された名前のステップのステップビルダーを初期化します。- パラメーター:
name
- ステップの名前jobRepository
- ステップが報告するジョブリポジトリ- 導入:
- 5.0
メソッドの詳細
inputChannel
public RemotePartitioningWorkerStepBuilder inputChannel(org.springframework.messaging.MessageChannel inputChannel) マネージャーから送信されたステップ実行リクエストを受信する入力チャネルを設定します。- パラメーター:
inputChannel
- 入力チャンネル- 戻り値:
- 流れるような連鎖のためのこのビルダーインスタンス
outputChannel
public RemotePartitioningWorkerStepBuilder outputChannel(org.springframework.messaging.MessageChannel outputChannel) 応答がマネージャーステップに送信される出力チャネルを設定します。- パラメーター:
outputChannel
- 入力チャンネル- 戻り値:
- 流れるような連鎖のためのこのビルダーインスタンス
jobExplorer
Job Explorer を設定します。- パラメーター:
jobExplorer
- 使用する求職者- 戻り値:
- 流れるような連鎖のためのこのビルダーインスタンス
stepLocator
実行するワーカーステップを見つけるために使用されるステップロケーターを設定します。- パラメーター:
stepLocator
- 使用するステップロケーター- 戻り値:
- 流れるような連鎖のためのこのビルダーインスタンス
beanFactory
public RemotePartitioningWorkerStepBuilder beanFactory(org.springframework.beans.factory.BeanFactory beanFactory) Bean ファクトリを設定します。- パラメーター:
beanFactory
- Bean ファクトリ- 戻り値:
- 流れるような連鎖のためのこのビルダーインスタンス
repository
@DeprecatedSE(since="5.1", forRemoval=true) public RemotePartitioningWorkerStepBuilder repository(JobRepository jobRepository) 非推奨、削除予定: この API 要素は、将来のバージョンで削除される可能性があります。ジョブリポジトリを設定する- オーバーライド:
- クラス
StepBuilderHelper<StepBuilder>
のrepository
- パラメーター:
jobRepository
- 設定するリポジトリ- 戻り値:
- これは流れるような連鎖を可能にする
startLimit
- オーバーライド:
- クラス
StepBuilderHelper<StepBuilder>
のstartLimit
listener
クラスからコピーされた説明:StepBuilderHelper
アノテーションベースのリスナー構成を使用してオブジェクトを登録します。- オーバーライド:
- クラス
StepBuilderHelper<StepBuilder>
のlistener
- パラメーター:
listener
- リスナーアノテーションで設定されたメソッドを持つオブジェクト- 戻り値:
- 流れるようなチェーン用
listener
- オーバーライド:
- クラス
StepBuilderHelper<StepBuilder>
のlistener
allowStartIfComplete
- オーバーライド:
- クラス
StepBuilderHelper<StepBuilder>
のallowStartIfComplete
tasklet
非推奨、削除予定: この API 要素は、将来のバージョンで削除される可能性があります。クラスからコピーされた説明:StepBuilder
必ずしもアイテム処理ではなく、カスタムタスクレットでステップを作成します。- オーバーライド:
- クラス
StepBuilder
のtasklet
- パラメーター:
tasklet
- タスクレット- 戻り値:
TaskletStepBuilder
tasklet
public TaskletStepBuilder tasklet(Tasklet tasklet, org.springframework.transaction.PlatformTransactionManager transactionManager) クラスからコピーされた説明:StepBuilder
必ずしもアイテム処理ではなく、カスタムタスクレットでステップを作成します。- オーバーライド:
- クラス
StepBuilder
のtasklet
- パラメーター:
tasklet
- タスクレットtransactionManager
- タスクレットに使用するトランザクションマネージャー- 戻り値:
TaskletStepBuilder
chunk
@DeprecatedSE(since="5.0", forRemoval=true) public <I,O> SimpleStepBuilder<I,O> chunk(int chunkSize) 非推奨、削除予定: この API 要素は、将来のバージョンで削除される可能性があります。クラスからコピーされた説明:StepBuilder
指定されたサイズでアイテムをチャンクで処理するステップを作成します。ステップをフォールトトレラントに拡張するには、ビルダーでSimpleStepBuilder.faultTolerant()
メソッドを呼び出します。ほとんどの場合、このメソッドの呼び出しをパラメーター化して、リーダーとライターの型の安全性を維持する必要があります。new StepBuilder("step1").<Order, Ledger> chunk(100).reader(new OrderReader()).writer(new LedgerWriter()) // ... etc.
- オーバーライド:
- クラス
StepBuilder
のchunk
- 型パラメーター:
I
- 入力として処理されるアイテムの型O
- 出力する項目の種類- パラメーター:
chunkSize
- チャンクサイズ (コミット間隔)- 戻り値:
SimpleStepBuilder
chunk
public <I,O> SimpleStepBuilder<I,O> chunk(int chunkSize, org.springframework.transaction.PlatformTransactionManager transactionManager) クラスからコピーされた説明:StepBuilder
指定されたサイズでアイテムをチャンクで処理するステップを作成します。ステップをフォールトトレラントに拡張するには、ビルダーでSimpleStepBuilder.faultTolerant()
メソッドを呼び出します。ほとんどの場合、このメソッドの呼び出しをパラメーター化して、リーダーとライターの型の安全性を維持する必要があります。new StepBuilder("step1").<Order, Ledger> chunk(100, transactionManager).reader(new OrderReader()).writer(new LedgerWriter()) // ... etc.
- オーバーライド:
- クラス
StepBuilder
のchunk
- 型パラメーター:
I
- 入力として処理されるアイテムの型O
- 出力する項目の種類- パラメーター:
chunkSize
- チャンクサイズ (コミット間隔)transactionManager
- チャンク指向のタスクレットに使用するトランザクションマネージャー- 戻り値:
SimpleStepBuilder
chunk
@DeprecatedSE(since="5.0", forRemoval=true) public <I,O> SimpleStepBuilder<I,O> chunk(CompletionPolicy completionPolicy) 非推奨、削除予定: この API 要素は、将来のバージョンで削除される可能性があります。クラスからコピーされた説明:StepBuilder
提供された完了ポリシーを使用して、項目をチャンクで処理するステップを構築します。ステップをフォールトトレラントに拡張するには、ビルダーでSimpleStepBuilder.faultTolerant()
メソッドを呼び出します。ほとんどの場合、このメソッドの呼び出しをパラメーター化して、リーダーとライターの型の安全性を維持する必要があります。new StepBuilder("step1").<Order, Ledger> chunk(100).reader(new OrderReader()).writer(new LedgerWriter()) // ... etc.
- オーバーライド:
- クラス
StepBuilder
のchunk
- 型パラメーター:
I
- 入力として処理されるアイテムの型O
- 出力する項目の種類- パラメーター:
completionPolicy
- チャンク処理を制御するために使用する完了ポリシー- 戻り値:
SimpleStepBuilder
chunk
public <I,O> SimpleStepBuilder<I,O> chunk(CompletionPolicy completionPolicy, org.springframework.transaction.PlatformTransactionManager transactionManager) クラスからコピーされた説明:StepBuilder
提供された完了ポリシーを使用して、項目をチャンクで処理するステップを構築します。ステップをフォールトトレラントに拡張するには、ビルダーでSimpleStepBuilder.faultTolerant()
メソッドを呼び出します。ほとんどの場合、このメソッドの呼び出しをパラメーター化して、リーダーとライターの型の安全性を維持する必要があります。new StepBuilder("step1").<Order, Ledger> chunk(100, transactionManager).reader(new OrderReader()).writer(new LedgerWriter()) // ... etc.
- オーバーライド:
- クラス
StepBuilder
のchunk
- 型パラメーター:
I
- 入力として処理されるアイテムの型O
- 出力する項目の種類- パラメーター:
completionPolicy
- チャンク処理を制御するために使用する完了ポリシーtransactionManager
- チャンク指向のタスクレットに使用するトランザクションマネージャー- 戻り値:
SimpleStepBuilder
partitioner
クラスからコピーされた説明:StepBuilder
リモート(またはローカル)ステップ用のパーティションステップビルダーを作成します。- オーバーライド:
- クラス
StepBuilder
のpartitioner
- パラメーター:
stepName
- リモートまたはデリゲートステップの名前partitioner
- 新しいステップ実行を構築するために使用されるパーティショナー- 戻り値:
PartitionStepBuilder
partitioner
クラスからコピーされた説明:StepBuilder
リモート(またはローカル)ステップ用のパーティションステップビルダーを作成します。- オーバーライド:
- クラス
StepBuilder
のpartitioner
- パラメーター:
step
- 並行して実行するステップ- 戻り値:
- PartitionStepBuilder
job
クラスからコピーされた説明:StepBuilder
ジョブを実行する新しいステップビルダーを作成します。- オーバーライド:
- クラス
StepBuilder
のjob
- パラメーター:
job
- 実行するジョブ- 戻り値:
JobStepBuilder
flow
クラスからコピーされた説明:StepBuilder
フローを実行する新しいステップビルダーを作成します。- オーバーライド:
- クラス
StepBuilder
のflow
- パラメーター:
flow
- 実行するフロー- 戻り値:
FlowStepBuilder
RemotePartitioningWorkerStepBuilder(String, JobRepository)
を使用