コンストラクターの詳細

• AbstractPartitionHandler

  public AbstractPartitionHandler()

  新しい抽象パーティションハンドラーをインスタンス化します。

• AbstractPartitionHandler

  public AbstractPartitionHandler(BatchYarnAppmaster batchAppmaster)

  新しい抽象パーティションハンドラーをインスタンス化します。

  パラメーター:

  batchAppmaster - バッチアプリマスター

メソッドの詳細

• handle

  public final java.util.Collection<org.springframework.batch.core.StepExecution> handle(org.springframework.batch.core.partition.StepExecutionSplitter stepSplitter,
                                                                          org.springframework.batch.core.StepExecution stepExecution)
                                                                                  throws java.lang.Exception

  次で指定:

  インターフェース org.springframework.batch.core.partition.PartitionHandler 内の handle 

  例外:

  java.lang.Exception

• setBatchAppmaster

  public void setBatchAppmaster(BatchYarnAppmaster batchAppmaster)

  バッチアプリマスターを設定します。

  パラメーター:

  batchAppmaster - 新しいバッチアプリマスター

  関連事項:

  setYarnAppmaster(YarnAppmaster)

• setYarnAppmaster

  public void setYarnAppmaster(YarnAppmaster yarnAppmaster)

  バッチアプリマスターを設定します。これは、コンテキスト内の型が YarnAppmaster として定義されている場合に、アプリケーションコンテキストが BatchYarnAppmaster を自動的に接続できるようにするために YarnAppmaster を使用する特定の方法です。

  パラメーター:

  yarnAppmaster - 新しい糸アプリマスター

  関連事項:

  setBatchAppmaster(BatchYarnAppmaster)

• setKeySplitLocations

  public void setKeySplitLocations(java.lang.String keySplitLocations)

  各 ExecutionContext 内の分割場所のキーの名前。デフォルトは "splitLocations" です。

  パラメーター:

  keySplitLocations - キーの値

• getKeySplitLocations

  public java.lang.String getKeySplitLocations()

  キー分割場所を取得します。

  戻り値:

  主要な分割場所

• getStepName

  public java.lang.String getStepName()

  リモートステップ名を取得します。

  戻り値:

  リモートステップ名

• setStepName

  public void setStepName(java.lang.String stepName)

  リモートステップ名を設定します。

  パラメーター:

  stepName - 新しいリモートステップ名

• createSplits

  protected abstract java.util.Set<org.springframework.batch.core.StepExecution> createSplits(org.springframework.batch.core.partition.StepExecutionSplitter stepSplitter,
                                                                         org.springframework.batch.core.StepExecution stepExecution)
                                                                                       throws java.lang.Exception

  分割を作成します。実装者は、実際のステップ分割を作成するにはこのメソッドをオーバーライドする必要があります。

  パラメーター:

  stepSplitter - ステップスプリッター

  stepExecution - ステップ実行

  戻り値:

  ステップ実行

  例外:

  java.lang.Exception - 例外

• createRequestData

  protected java.util.Map<org.springframework.batch.core.StepExecution,ContainerRequestHint> createRequestData(java.util.Set<org.springframework.batch.core.StepExecution> stepExecutions)
                                                                                                        throws java.lang.Exception

  サブクラスはこのメソッドをオーバーライドして、特定の ContainerRequestHint を StepExecution に割り当てることができます。これは、データの局所性を考慮して特定のホストまたはラックでステップを実行する必要がある場合に必要になります。

  デフォルトの実装では空のマップが返されます。

  パラメーター:

  stepExecutions - ステップ実行のセット

  戻り値:

  ステップ実行とコンテナーリクエストデータ間のマッピング

  例外:

  java.lang.Exception - エラーが発生した場合

• waitCompleteState

  protected void waitCompleteState(org.springframework.batch.core.StepExecution masterStepExecution)

  CountDownLatch を使用して、アプリケーションマスターからの完了ステータスを待機します。マスター自体または親ステップ実行のいずれかが完了ステータスを送信すると、ステータスは完了したと見なされます。

  パラメーター:

  masterStepExecution - 親ステップの実行