org.springframework.yarn.batch.am

Interface BatchYarnAppmaster

All Superinterfaces:

YarnAppmaster

All Known Implementing Classes:

AbstractBatchAppmaster, BatchAppmaster

public interface BatchYarnAppmaster
extends YarnAppmaster

Extended interface YarnAppmasters used with Spring Batch.

Author:

Janne Valkealahti

Method Summary

Methods

Modifier and Type	Method and Description
void	addPartitionedStepExecutionStateListener(PartitionedStepExecutionStateListener partitionedStepExecutionStateListener) Adds the partitioned step execution state listener.
void	addStepSplits(org.springframework.batch.core.StepExecution stepExecution, java.lang.String stepName, java.util.Set<org.springframework.batch.core.StepExecution> split, java.util.Map<org.springframework.batch.core.StepExecution,ContainerRequestHint> resourceRequests) Adds the step splits.
java.util.Collection<? extends org.springframework.batch.core.StepExecution>	getStepExecutions() Gets the step executions.

Methods inherited from interface org.springframework.yarn.am.YarnAppmaster

addAppmasterStateListener, setEnvironment, setParameters, submitApplication

Method Detail

addStepSplits

void addStepSplits(org.springframework.batch.core.StepExecution stepExecution,
                 java.lang.String stepName,
                 java.util.Set<org.springframework.batch.core.StepExecution> split,
                 java.util.Map<org.springframework.batch.core.StepExecution,ContainerRequestHint> resourceRequests)

Adds the step splits.

Parameters:

stepExecution - the step execution

stepName - the step name

split - the step execution splits

resourceRequests - the resource requests

getStepExecutions

java.util.Collection<? extends org.springframework.batch.core.StepExecution> getStepExecutions()

Gets the step executions.

Returns:

the step executions

addPartitionedStepExecutionStateListener

void addPartitionedStepExecutionStateListener(PartitionedStepExecutionStateListener partitionedStepExecutionStateListener)

Adds the partitioned step execution state listener.

Parameters:

partitionedStepExecutionStateListener - the partitioned step execution state listener