|
|||||||||
| PREV NEXT | FRAMES NO FRAMES | ||||||||
YarnContainer extending
AbstractIntegrationYarnContainer adding functionality
for Spring Batch.Partitioner.PartitionHandler handling
partitioning for Yarn containers.AppmasterScOperations.AppmasterMindScOperations.
JobRepository.add(StepExecution).JobRepository.add(StepExecution).YarnAppmasters used with Spring Batch.StepLocator implementation that just looks in its enclosing bean
factory for components of type Step.ExecutionContext to ExecutionContextType.
ExecutionContextType to ExecutionContext.
JobExecutionType from JobExecution.
JobExecutionType from JobExecution.
JobExecutionType to JobExecution.
JobInstance to JobInstanceType.
JobInstanceType to JobInstance.
JobParameters to JobParametersType.
JobParametersType to JobParameters.
StepExecutionType from StepExecution.
StepExecutionType from StepExecution.
StepExecutionType to StepExecution.
JobRepository.createJobExecution(String, JobParameters).JobRepository.createJobExecution(String, JobParameters).JobRepository.createJobExecution(JobInstance, JobParameters, String).JobRepository.createJobExecution(String, JobParameters).JobRepository.createJobExecution(String, JobParameters).JobRepository.createJobInstance(String, JobParameters).ExecutionContexts for partitions.
ContainerRequestHint to
a StepExecution.
ItemReader able
to read items from HDFS file splits.AbstractBatchYarnContainer
to handle Spring Batch remote steps.ExecutionContext.JobExplorer.findRunningJobExecutions(String).JobExplorer.findRunningJobExecutions(String).AppmasterMindScOperations for this implementation.
JobExplorer.getJobExecution(Long).JobExplorer.getJobExecution(Long).JobExplorer.getJobExecutions(JobInstance).JobExplorer.getJobExecutions(JobInstance).JobExplorer.getJobInstanceCount(String).JobExplorer.getJobInstanceCount(String).JobExplorer.getJobInstance(Long).JobExplorer.getJobInstance(Long).JobExplorer.getJobInstances(String, int, int).JobExplorer.getJobInstances(String, int, int).JobExplorer.getJobNames().JobExplorer.getJobNames().JobRepository.getLastJobExecution(String, JobParameters).JobRepository.getLastJobExecution(String, JobParameters).JobRepository.getLastStepExecution(JobInstance, String).JobRepository.getLastStepExecution(JobInstance, String).Step.
JobRepository.getStepExecutionCount(JobInstance, String).JobRepository.getStepExecutionCount(JobInstance, String).JobExplorer.getStepExecution(Long, Long).JobExplorer.getStepExecution(Long, Long).Step.
null
from a JobRepositoryRemoteServiceInterceptor.preRequest(BaseObject) method.
JobRepository.isJobInstanceExists(String, JobParameters).JobRepository.isJobInstanceExists(String, JobParameters).JobExecution
has happened.StepExecution.
JobExecution.JobInstance.JobParameters.JobParameter.BaseObject and BaseResponseObject.StepExecution state
has been changed.StepExecution.
PartitionedStepExecutionStatusReq.LineDataMapper implementation which just passes data as it is.BaseObject
and before BaseResponseObject is sent to further
processing.
BaseObject.
AppmasterMindScOperations for this implementation.
StepExecutionSplitter in the
AbstractPartitionHandler.handle(StepExecutionSplitter, StepExecution) method, instructing
it how many StepExecution instances are required, ideally.
JobParametersConverter.
ExecutionContext.
ExecutionContext.
ExecutionContext.
ExecutionContext.
ExecutionContext.
ExecutionContext.
ExecutionContext.
Partitioner that locates multiple resources and
associates their file names with execution context keys.PartitionHandler which does
partitioning based on number of input files from HDFS.PartitionHandler which does
partitioning based on static grid size.StepExecution.JobRepository.updateExecutionContext(JobExecution)
and JobRepository.updateExecutionContext(StepExecution).JobRepository.updateExecutionContext(JobExecution)
and JobRepository.updateExecutionContext(StepExecution).JobRepository.update(JobExecution).JobRepository.update(JobExecution).JobRepository.update(StepExecution).JobRepository.update(StepExecution).CountDownLatch to wait completion status from
application master.
|
|||||||||
| PREV NEXT | FRAMES NO FRAMES | ||||||||