クラス RemotePartitioningManagerStepBuilder
java.lang.ObjectSE
org.springframework.batch.core.step.builder.StepBuilderHelper<PartitionStepBuilder>
org.springframework.batch.core.step.builder.PartitionStepBuilder
org.springframework.batch.integration.partition.RemotePartitioningManagerStepBuilder
リモートパーティショニングセットアップのマネージャーステップのビルダー。このビルダーは、マネージャーステップで
MessageChannelPartitionHandler を作成および設定します。messagingTemplate(MessagingTemplate) を介して messagingTemplate が提供されない場合、このビルダーは、outputChannel(MessageChannel) を介して提供される outputChannel にデフォルトチャンネルを作成して設定します。
messagingTemplate が提供される場合、完全に構成され、そのデフォルトチャネルはワーカーへのリクエストが送信される出力チャネルに設定されていると想定されます。
- 導入:
- 4.2
- 作成者:
- Mahmoud Ben Hassine
ネストされたクラスの要約
クラス org.springframework.batch.core.step.builder.StepBuilderHelper から継承されたネストクラス / インターフェース
StepBuilderHelper.CommonStepPropertiesフィールドのサマリー
クラス org.springframework.batch.core.step.builder.StepBuilderHelper から継承されたフィールド
logger, propertiesコンストラクターの概要
コンストラクターコンストラクター説明RemotePartitioningManagerStepBuilder(StringSE stepName) 非推奨、削除予定: この API 要素は、将来のバージョンで削除される可能性があります。RemotePartitioningManagerStepBuilder(StringSE stepName, JobRepository jobRepository) 新しいRemotePartitioningManagerStepBuilderを作成します。メソッドのサマリー
修飾子と型メソッド説明aggregator(StepExecutionAggregator aggregator) 区分化されたステップ実行をPartitionStep自体の単一の結果に集約するためのステップ実行アグリゲーターを提供します。allowStartIfComplete(boolean allowStartIfComplete) beanFactory(org.springframework.beans.factory.BeanFactory beanFactory) Bean ファクトリを設定します。build()gridSize(int gridSize) 必要なステップ実行の数に関するPartitionStepBuilder.splitter(StepExecutionSplitter)へのヒント。inputChannel(org.springframework.messaging.MessageChannel inputChannel) ワーカーからの応答を受信する入力チャネルを設定します。jobExplorer(JobExplorer jobExplorer) Job Explorer を設定します。アノテーションベースのリスナー構成を使用してオブジェクトを登録します。listener(StepExecutionListener listener) messagingTemplate(org.springframework.integration.core.MessagingTemplate messagingTemplate) ワーカーにデータを送信するために使用するMessagingTemplateを設定します。outputChannel(org.springframework.messaging.MessageChannel outputChannel) ワーカーへのリクエストが送信される出力チャネルを設定します。partitioner(StringSE workerStepName, Partitioner partitioner) StepExecutionSplitterの作成に使用できるパーティショナーを追加します。partitionHandler(PartitionHandler partitionHandler) マネージャーステップのパーティションハンドラーがMessageChannelPartitionHandlerのインスタンスに自動的に設定されるため、このメソッドはUnsupportedOperationExceptionSE をスローします。pollInterval(long pollInterval) ワーカーのステータスについてジョブリポジトリをポーリングする頻度。repository(JobRepository jobRepository) 非推奨、削除予定: この API 要素は、将来のバージョンで削除される可能性があります。splitter(StepExecutionSplitter splitter) PartitionStepBuilder.partitioner(String, Partitioner)から 1 つのビルドを作成する代わりに、明示的なStepExecutionSplitterを提供します。startLimit(int startLimit) 並列実行する実際のステップインスタンスを提供します。timeout(long timeout) ジョブリポジトリのポーリングを使用する場合、待機する時間制限。クラス org.springframework.batch.core.step.builder.PartitionStepBuilder から継承されたメソッド
getAggregator, getGridSize, getPartitioner, getPartitionHandler, getSplitter, getStep, getStepName, getTaskExecutor, self, taskExecutorクラス org.springframework.batch.core.step.builder.StepBuilderHelper から継承されたメソッド
enhance, getJobRepository, getName, isAllowStartIfComplete, meterRegistry, observationConvention, observationRegistry
コンストラクターの詳細
RemotePartitioningManagerStepBuilder
@DeprecatedSE(since="5.0", forRemoval=true) public RemotePartitioningManagerStepBuilder(StringSE stepName) 非推奨、削除予定: この API 要素は、将来のバージョンで削除される可能性があります。新しいRemotePartitioningManagerStepBuilderを作成します。- パラメーター:
stepName- マネージャーステップの名前
RemotePartitioningManagerStepBuilder
新しいRemotePartitioningManagerStepBuilderを作成します。- パラメーター:
stepName- マネージャーステップの名前jobRepository- ステップのレポート先のジョブリポジトリ- 導入:
- 5.0
メソッドの詳細
inputChannel
public RemotePartitioningManagerStepBuilder inputChannel(org.springframework.messaging.MessageChannel inputChannel) ワーカーからの応答を受信する入力チャネルを設定します。- パラメーター:
inputChannel- 入力チャンネル- 戻り値:
- 流れるような連鎖のためのこのビルダーインスタンス
outputChannel
public RemotePartitioningManagerStepBuilder outputChannel(org.springframework.messaging.MessageChannel outputChannel) ワーカーへのリクエストが送信される出力チャネルを設定します。この setter を使用することにより、デフォルトのメッセージングテンプレートが作成され、出力チャネルがデフォルトチャネルとして設定されます。この setter または
messagingTemplate(MessagingTemplate)のいずれかを使用して、完全に構成されたメッセージングテンプレートを提供します。- パラメーター:
outputChannel- 出力チャンネル。- 戻り値:
- 流れるような連鎖のためのこのビルダーインスタンス
- 関連事項:
messagingTemplate
public RemotePartitioningManagerStepBuilder messagingTemplate(org.springframework.integration.core.MessagingTemplate messagingTemplate) ワーカーにデータを送信するために使用するMessagingTemplateを設定します。メッセージングテンプレートのデフォルトチャネルを設定する必要がありますこの setter を使用して、完全に構成されたメッセージングテンプレートを提供するか、
outputChannel(MessageChannel)を介して出力チャネルを提供すると、デフォルトのメッセージングテンプレートが作成されます。- パラメーター:
messagingTemplate- 使用するメッセージングテンプレート- 戻り値:
- 流れるような連鎖のためのこのビルダーインスタンス
- 関連事項:
jobExplorer
Job Explorer を設定します。- パラメーター:
jobExplorer- 使用する Job Explorer。- 戻り値:
- 流れるような連鎖のためのこのビルダーインスタンス
pollInterval
ワーカーのステータスについてジョブリポジトリをポーリングする頻度。デフォルトは 10 秒です。- パラメーター:
pollInterval- ポーリング間隔値(ミリ秒)- 戻り値:
- 流れるような連鎖のためのこのビルダーインスタンス
timeout
ジョブリポジトリのポーリングを使用する場合、待機する時間制限。デフォルトは -1(タイムアウトなし)です。- パラメーター:
timeout- ミリ秒単位のタイムアウト値- 戻り値:
- 流れるような連鎖のためのこのビルダーインスタンス
beanFactory
public RemotePartitioningManagerStepBuilder beanFactory(org.springframework.beans.factory.BeanFactory beanFactory) Bean ファクトリを設定します。- パラメーター:
beanFactory- 使用する Bean ファクトリ- 戻り値:
- 流れるような連鎖のためのこのビルダーインスタンス
build
- オーバーライド:
- クラス
PartitionStepBuilderのbuild
repository
@DeprecatedSE(since="5.1", forRemoval=true) public RemotePartitioningManagerStepBuilder repository(JobRepository jobRepository) 非推奨、削除予定: この API 要素は、将来のバージョンで削除される可能性があります。ジョブリポジトリを設定する- オーバーライド:
- クラス
StepBuilderHelper<PartitionStepBuilder>のrepository - パラメーター:
jobRepository- 設定するリポジトリ- 戻り値:
- これは流れるような連鎖を可能にする
partitioner
public RemotePartitioningManagerStepBuilder partitioner(StringSE workerStepName, Partitioner partitioner) クラスからコピーされた説明:PartitionStepBuilderStepExecutionSplitterの作成に使用できるパーティショナーを追加します。これまたは明示的なPartitionStepBuilder.splitter(StepExecutionSplitter)のいずれかを使用しますが、両方は使用しません。- オーバーライド:
- クラス
PartitionStepBuilderのpartitioner - パラメーター:
workerStepName- ワーカーステップの名前 (ステップ実行名の作成に使用)partitioner- 使用するパーティショナー- 戻り値:
- 流れるようなチェーン用
gridSize
クラスからコピーされた説明:PartitionStepBuilder必要なステップ実行の数に関するPartitionStepBuilder.splitter(StepExecutionSplitter)へのヒント。PartitionStepBuilder.taskExecutor(TaskExecutor)を介してローカルまたはリモートで実行する場合、パーティションのステップ実行の最初の試行でのステップ実行の数を正確に決定します。- オーバーライド:
- クラス
PartitionStepBuilderのgridSize - パラメーター:
gridSize- グリッドサイズ- 戻り値:
- 流れるようなチェーン用
step
クラスからコピーされた説明:PartitionStepBuilder並列実行する実際のステップインスタンスを提供します。明示的なPartitionStepBuilder.partitionHandler(PartitionHandler)が提供される場合、ステップはオプションであり、構成データ(ステップの名前およびその他の基本プロパティ)を抽出するためにのみ使用されます。- オーバーライド:
- クラス
PartitionStepBuilderのstep - パラメーター:
step- 並行して実行するステップ- 戻り値:
- 流れるようなチェーン用
splitter
クラスからコピーされた説明:PartitionStepBuilderPartitionStepBuilder.partitioner(String, Partitioner)から 1 つのビルドを作成する代わりに、明示的なStepExecutionSplitterを提供します。分割をさらに制御する必要がある場合に便利です。- オーバーライド:
- クラス
PartitionStepBuilderのsplitter - パラメーター:
splitter- ステップ実行スプリッター- 戻り値:
- 流れるようなチェーン用
aggregator
クラスからコピーされた説明:PartitionStepBuilder区分化されたステップ実行をPartitionStep自体の単一の結果に集約するためのステップ実行アグリゲーターを提供します。デフォルトは、ほとんどの場合に機能する単純な実装です。- オーバーライド:
- クラス
PartitionStepBuilderのaggregator - パラメーター:
aggregator- ステップ実行アグリゲーター- 戻り値:
- 流れるようなチェーン用
startLimit
- オーバーライド:
- クラス
StepBuilderHelper<PartitionStepBuilder>のstartLimit
listener
クラスからコピーされた説明:StepBuilderHelperアノテーションベースのリスナー構成を使用してオブジェクトを登録します。- オーバーライド:
- クラス
StepBuilderHelper<PartitionStepBuilder>のlistener - パラメーター:
listener- リスナーアノテーションで設定されたメソッドを持つオブジェクト- 戻り値:
- 流れるようなチェーン用
listener
- オーバーライド:
- クラス
StepBuilderHelper<PartitionStepBuilder>のlistener
allowStartIfComplete
- オーバーライド:
- クラス
StepBuilderHelper<PartitionStepBuilder>のallowStartIfComplete
partitionHandler
public RemotePartitioningManagerStepBuilder partitionHandler(PartitionHandler partitionHandler) throws UnsupportedOperationExceptionSE マネージャーステップのパーティションハンドラーがMessageChannelPartitionHandlerのインスタンスに自動的に設定されるため、このメソッドはUnsupportedOperationExceptionSE をスローします。このビルダーを使用して リモートパーティション化のマネージャーステップを構築する場合、パーティションハンドラーを指定する必要はありません。
- オーバーライド:
- クラス
PartitionStepBuilderのpartitionHandler - パラメーター:
partitionHandler- パーティションハンドラー- 戻り値:
- 流れるような連鎖のためのこのビルダーインスタンス
- 例外:
UnsupportedOperationExceptionSE- パーティションハンドラーが提供されている場合- 関連事項:
RemotePartitioningManagerStepBuilder(String, JobRepository)を使用