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, waitCompleteState
public 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.Exception
AbstractPartitionHandler
AbstractPartitionHandler
の createSplits
stepSplitter
- ステップスプリッター stepExecution
- ステップ実行 java.lang.Exception
- 例外 public void setGridSize(int gridSize)
AbstractPartitionHandler.handle(StepExecutionSplitter, StepExecution)
メソッドで StepExecutionSplitter
に渡され、理想的には必要な StepExecution
インスタンスの数を指示します。入力データパーティションを保持する必要があるため、StepExecutionSplitter
は再起動時にグリッドサイズを無視できます。gridSize
- 作成されるステップ実行の数