|
Spring for Apache Hadoop | ||||||||
| PREV CLASS NEXT CLASS | FRAMES NO FRAMES | ||||||||
| SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD | ||||||||
java.lang.Objectorg.springframework.yarn.batch.partition.AbstractBatchPartitionHandler
org.springframework.yarn.batch.partition.StaticBatchPartitionHandler
public class StaticBatchPartitionHandler
Implementation of Spring Batch PartitionHandler which does
partitioning based on static grid size.
| Constructor Summary | |
|---|---|
StaticBatchPartitionHandler()
Instantiates a new static batch partition handler. |
|
StaticBatchPartitionHandler(BatchYarnAppmaster batchAppmaster)
Instantiates a new static batch partition handler. |
|
StaticBatchPartitionHandler(BatchYarnAppmaster batchAppmaster,
int gridSize)
Instantiates a new static batch partition handler. |
|
| Method Summary | |
|---|---|
protected java.util.Set<org.springframework.batch.core.StepExecution> |
createStepExecutionSplits(org.springframework.batch.core.partition.StepExecutionSplitter stepSplitter,
org.springframework.batch.core.StepExecution stepExecution)
|
void |
setGridSize(int gridSize)
Passed to the StepExecutionSplitter in the
AbstractBatchPartitionHandler.handle(StepExecutionSplitter, StepExecution) method, instructing
it how many StepExecution instances are required, ideally. |
| Methods inherited from class org.springframework.yarn.batch.partition.AbstractBatchPartitionHandler |
|---|
createResourceRequestData, getContainerResolver, getStepName, handle, setBatchAppmaster, setContainerResolver, setStepName, setYarnAppmaster, waitCompleteState |
| Methods inherited from class java.lang.Object |
|---|
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait |
| Constructor Detail |
|---|
public StaticBatchPartitionHandler()
public StaticBatchPartitionHandler(BatchYarnAppmaster batchAppmaster)
batchAppmaster - the batch appmaster
public StaticBatchPartitionHandler(BatchYarnAppmaster batchAppmaster,
int gridSize)
batchAppmaster - the batch appmastergridSize - the grid size| Method Detail |
|---|
public void setGridSize(int gridSize)
StepExecutionSplitter in the
AbstractBatchPartitionHandler.handle(StepExecutionSplitter, StepExecution) method, instructing
it how many StepExecution instances are required, ideally. The
StepExecutionSplitter is allowed to ignore the grid size in the
case of a restart, since the input data partitions must be preserved.
gridSize - the number of step executions that will be created
protected java.util.Set<org.springframework.batch.core.StepExecution> createStepExecutionSplits(org.springframework.batch.core.partition.StepExecutionSplitter stepSplitter,
org.springframework.batch.core.StepExecution stepExecution)
throws java.lang.Exception
createStepExecutionSplits in class AbstractBatchPartitionHandlerjava.lang.Exception
|
Spring for Apache Hadoop | ||||||||
| PREV CLASS NEXT CLASS | FRAMES NO FRAMES | ||||||||
| SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD | ||||||||