クラス RemotePartitioningWorkerStepBuilder


public class RemotePartitioningWorkerStepBuilder extends StepBuilder
リモートパーティション設定のワーカーステップのビルダー。このビルダーは、以下を行う IntegrationFlow を作成します。
  • 入力チャネルのマネージャーからの StepExecutionRequest をリッスンします
  • StepExecutionRequestHandler を呼び出して、受信リクエストごとにワーカーステップを実行します。ワーカーステップは、提供された StepLocator を使用して見つけられます。StepLocator が提供されない場合、現在の BeanFactory で構成された BeanFactoryStepLocator が使用されます
  • 出力チャネルでマネージャーに応答します (マネージャーステップが ワーカー からの応答を集約するように構成されている場合)。出力チャンネルが提供されていない場合は、NullChannel が使用されます (マネージャー側が ワーカーステータスのジョブリポジトリをポーリングするように構成されていると仮定します)
導入:
4.1
作成者:
Mahmoud Ben Hassine
  • コンストラクターの詳細

    • RemotePartitioningWorkerStepBuilder

      @DeprecatedSE(since="5.0", forRemoval=true) public RemotePartitioningWorkerStepBuilder(StringSE name)
      非推奨、削除予定: この API 要素は、将来のバージョンで削除される可能性があります。
      指定された名前のステップのステップビルダーを初期化します。
      パラメーター:
      name - ステップの名前
    • RemotePartitioningWorkerStepBuilder

      public RemotePartitioningWorkerStepBuilder(StringSE name, JobRepository jobRepository)
      指定された名前のステップのステップビルダーを初期化します。
      パラメーター:
      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

      public RemotePartitioningWorkerStepBuilder jobExplorer(JobExplorer jobExplorer)
      Job Explorer を設定します。
      パラメーター:
      jobExplorer - 使用する求職者
      戻り値:
      流れるような連鎖のためのこのビルダーインスタンス
    • stepLocator

      public RemotePartitioningWorkerStepBuilder stepLocator(StepLocator 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

      public RemotePartitioningWorkerStepBuilder startLimit(int startLimit)
      オーバーライド:
      クラス StepBuilderHelper<StepBuilder>startLimit 
    • listener

      public RemotePartitioningWorkerStepBuilder listener(ObjectSE listener)
      クラスからコピーされた説明: StepBuilderHelper
      アノテーションベースのリスナー構成を使用してオブジェクトを登録します。
      オーバーライド:
      クラス StepBuilderHelper<StepBuilder>listener 
      パラメーター:
      listener - リスナーアノテーションで設定されたメソッドを持つオブジェクト
      戻り値:
      流れるようなチェーン用
    • listener

      オーバーライド:
      クラス StepBuilderHelper<StepBuilder>listener 
    • allowStartIfComplete

      public RemotePartitioningWorkerStepBuilder allowStartIfComplete(boolean allowStartIfComplete)
      オーバーライド:
      クラス StepBuilderHelper<StepBuilder>allowStartIfComplete 
    • tasklet

      @DeprecatedSE(since="5.0", forRemoval=true) public TaskletStepBuilder tasklet(Tasklet tasklet)
      非推奨、削除予定: この API 要素は、将来のバージョンで削除される可能性があります。
      クラスからコピーされた説明: StepBuilder
      必ずしもアイテム処理ではなく、カスタムタスクレットでステップを作成します。
      オーバーライド:
      クラス StepBuildertasklet 
      パラメーター:
      tasklet - タスクレット
      戻り値:
      TaskletStepBuilder
    • tasklet

      public TaskletStepBuilder tasklet(Tasklet tasklet, org.springframework.transaction.PlatformTransactionManager transactionManager)
      クラスからコピーされた説明: StepBuilder
      必ずしもアイテム処理ではなく、カスタムタスクレットでステップを作成します。
      オーバーライド:
      クラス StepBuildertasklet 
      パラメーター:
      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.
       
      オーバーライド:
      クラス StepBuilderchunk 
      型パラメーター:
      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.
       
      オーバーライド:
      クラス StepBuilderchunk 
      型パラメーター:
      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.
       
      オーバーライド:
      クラス StepBuilderchunk 
      型パラメーター:
      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.
       
      オーバーライド:
      クラス StepBuilderchunk 
      型パラメーター:
      I - 入力として処理されるアイテムの型
      O - 出力する項目の種類
      パラメーター:
      completionPolicy - チャンク処理を制御するために使用する完了ポリシー
      transactionManager - チャンク指向のタスクレットに使用するトランザクションマネージャー
      戻り値:
      SimpleStepBuilder
    • partitioner

      public PartitionStepBuilder partitioner(StringSE stepName, Partitioner partitioner)
      クラスからコピーされた説明: StepBuilder
      リモート(またはローカル)ステップ用のパーティションステップビルダーを作成します。
      オーバーライド:
      クラス StepBuilderpartitioner 
      パラメーター:
      stepName - リモートまたはデリゲートステップの名前
      partitioner - 新しいステップ実行を構築するために使用されるパーティショナー
      戻り値:
      PartitionStepBuilder
    • partitioner

      public PartitionStepBuilder partitioner(Step step)
      クラスからコピーされた説明: StepBuilder
      リモート(またはローカル)ステップ用のパーティションステップビルダーを作成します。
      オーバーライド:
      クラス StepBuilderpartitioner 
      パラメーター:
      step - 並行して実行するステップ
      戻り値:
      PartitionStepBuilder
    • job

      public JobStepBuilder job(Job job)
      クラスからコピーされた説明: StepBuilder
      ジョブを実行する新しいステップビルダーを作成します。
      オーバーライド:
      クラス StepBuilderjob 
      パラメーター:
      job - 実行するジョブ
      戻り値:
      JobStepBuilder
    • flow

      public FlowStepBuilder flow(Flow flow)
      クラスからコピーされた説明: StepBuilder
      フローを実行する新しいステップビルダーを作成します。
      オーバーライド:
      クラス StepBuilderflow 
      パラメーター:
      flow - 実行するフロー
      戻り値:
      FlowStepBuilder