public class StaticPartitionHandler extends AbstractPartitionHandler
PartitionHandler の実装。| コンストラクターと説明 |
|---|
StaticPartitionHandler() 新しい静的パーティションハンドラーをインスタンス化します。 |
StaticPartitionHandler(BatchYarnAppmaster batchAppmaster) 新しい静的パーティションハンドラーをインスタンス化します。 |
StaticPartitionHandler(BatchYarnAppmaster batchAppmaster, int gridSize) 新しい静的パーティションハンドラーをインスタンス化します。 |
| 修飾子と型 | メソッドと説明 |
|---|---|
protected java.util.Set<org.springframework.batch.core.StepExecution> | createSplits(org.springframework.batch.core.partition.StepExecutionSplitter stepSplitter, org.springframework.batch.core.StepExecution stepExecution) 分割を作成します。 |
void | setGridSize(int gridSize)AbstractPartitionHandler.handle(StepExecutionSplitter, StepExecution) メソッドで StepExecutionSplitter に渡され、理想的には必要な StepExecution インスタンスの数を指示します。 |
createRequestData, getKeySplitLocations, getStepName, handle, setBatchAppmaster, setKeySplitLocations, setStepName, setYarnAppmaster, waitCompleteStatepublic StaticPartitionHandler()
public StaticPartitionHandler(BatchYarnAppmaster batchAppmaster)
batchAppmaster - バッチアプリマスター public StaticPartitionHandler(BatchYarnAppmaster batchAppmaster, int gridSize)
batchAppmaster - バッチアプリマスター gridSize - グリッドサイズ protected 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.ExceptionAbstractPartitionHandlerAbstractPartitionHandler の createSplits stepSplitter - ステップスプリッター stepExecution - ステップ実行 java.lang.Exception - 例外 public void setGridSize(int gridSize)
AbstractPartitionHandler.handle(StepExecutionSplitter, StepExecution) メソッドで StepExecutionSplitter に渡され、理想的には必要な StepExecution インスタンスの数を指示します。入力データパーティションを保持する必要があるため、StepExecutionSplitter は再起動時にグリッドサイズを無視できます。gridSize - 作成されるステップ実行の数