A B C D E F G H I J L M O P R S T U V W

A

AbstractBatchAppmaster - Class in org.springframework.yarn.batch.am
Base application master for running batch jobs.
AbstractBatchAppmaster() - Constructor for class org.springframework.yarn.batch.am.AbstractBatchAppmaster
 
AbstractBatchPartitionHandler - Class in org.springframework.yarn.batch.partition
Base implementation of Spring Batch PartitionHandler handling partitioning for Yarn containers.
AbstractBatchPartitionHandler(AbstractBatchAppmaster) - Constructor for class org.springframework.yarn.batch.partition.AbstractBatchPartitionHandler
Instantiates a new batch partition handler.
AbstractBatchYarnContainer - Class in org.springframework.yarn.batch.container
Base implementation of YarnContainer extending AbstractIntegrationYarnContainer adding functionality for Spring Batch.
AbstractBatchYarnContainer() - Constructor for class org.springframework.yarn.batch.container.AbstractBatchYarnContainer
 
AbstractRemoteDao - Class in org.springframework.yarn.batch.repository
Base class for all daos handling remote calls through AppmasterScOperations.
AbstractRemoteDao() - Constructor for class org.springframework.yarn.batch.repository.AbstractRemoteDao
Default constructor.
AbstractRemoteDao(AppmasterMindScOperations) - Constructor for class org.springframework.yarn.batch.repository.AbstractRemoteDao
Constructor which sets the AppmasterMindScOperations.
add(JobRepositoryRemoteServiceInterceptor) - Method in class org.springframework.yarn.batch.repository.BatchAppmasterService.JobRepositoryServiceInterceptorList
Adds interceptor to the list.
addInterceptor(JobRepositoryRemoteServiceInterceptor) - Method in class org.springframework.yarn.batch.repository.BatchAppmasterService
Add a service interceptor to the end of the list.
addPartitionedStepExecutionStateListener(PartitionedStepExecutionStateListener) - Method in class org.springframework.yarn.batch.am.AbstractBatchAppmaster
Adds the partitioned step execution state listener.
addStepExecutions(JobExecution) - Method in class org.springframework.yarn.batch.repository.RemoteStepExecutionDao
 
AddStepExecutionsReq - Class in org.springframework.yarn.batch.repository.bindings
 
AddStepExecutionsReq() - Constructor for class org.springframework.yarn.batch.repository.bindings.AddStepExecutionsReq
 
AddStepExecutionsRes - Class in org.springframework.yarn.batch.repository.bindings
Response for adding step executions.
AddStepExecutionsRes() - Constructor for class org.springframework.yarn.batch.repository.bindings.AddStepExecutionsRes
 
addStepSplits(StepExecution, String, Set<StepExecution>, Map<StepExecution, ContainerRequestHint>) - Method in class org.springframework.yarn.batch.am.AbstractBatchAppmaster
Adds the step splits.
afterPropertiesSet() - Method in class org.springframework.yarn.batch.repository.JobRepositoryRemoteService
 
afterPropertiesSet() - Method in class org.springframework.yarn.batch.repository.RemoteJobExplorerFactoryBean
 
afterPropertiesSet() - Method in class org.springframework.yarn.batch.repository.RemoteJobRepositoryFactoryBean
 

B

BatchAppmaster - Class in org.springframework.yarn.batch.am
Implementation of application master which can be used to run Spring Batch jobs on Hadoop Yarn cluster.
BatchAppmaster() - Constructor for class org.springframework.yarn.batch.am.BatchAppmaster
 
BatchAppmasterService - Class in org.springframework.yarn.batch.repository
Application master service implementation which is used for remote Spring Batch steps to talk to Job Repository.
BatchAppmasterService() - Constructor for class org.springframework.yarn.batch.repository.BatchAppmasterService
 
BatchAppmasterService.JobRepositoryServiceInterceptorList - Class in org.springframework.yarn.batch.repository
Convenient wrapper for interceptor list.
BatchAppmasterService.JobRepositoryServiceInterceptorList() - Constructor for class org.springframework.yarn.batch.repository.BatchAppmasterService.JobRepositoryServiceInterceptorList
 
BatchMasterParser - Class in org.springframework.yarn.batch.config
Simple namespace parser for batch:master.
BatchMasterParser() - Constructor for class org.springframework.yarn.batch.config.BatchMasterParser
 
BatchNamespaceHandler - Class in org.springframework.yarn.batch.config
Handler for <yarn-batch> namespace.
BatchNamespaceHandler() - Constructor for class org.springframework.yarn.batch.config.BatchNamespaceHandler
 
BeanFactoryStepLocator - Class in org.springframework.yarn.batch.partition
A StepLocator implementation that just looks in its enclosing bean factory for components of type Step.
BeanFactoryStepLocator() - Constructor for class org.springframework.yarn.batch.partition.BeanFactoryStepLocator
 
buildAddStepExecutionsReq(JobExecution) - Static method in class org.springframework.yarn.batch.repository.JobRepositoryRpcFactory
Builds request for adding step executionf from a job execution.
buildCreateJobInstanceReq(String, JobParameters) - Static method in class org.springframework.yarn.batch.repository.JobRepositoryRpcFactory
Builds request for creating a job instance.
buildFindJobExecutionsReq(JobInstance) - Static method in class org.springframework.yarn.batch.repository.JobRepositoryRpcFactory
Builds request for finding a job execution by a job instance.
buildFindRunningJobExecutionsReq(String) - Static method in class org.springframework.yarn.batch.repository.JobRepositoryRpcFactory
Builds request for finding a job executions by a job name.
buildGetExecutionContextReq(StepExecution) - Static method in class org.springframework.yarn.batch.repository.JobRepositoryRpcFactory
Builds request for getting execution context from a step execution.
buildGetExecutionContextReq(JobExecution) - Static method in class org.springframework.yarn.batch.repository.JobRepositoryRpcFactory
Builds request for getting execution context from a job execution.
buildGetJobExecutionReq(Long) - Static method in class org.springframework.yarn.batch.repository.JobRepositoryRpcFactory
Builds request for getting a job execution by its execution id.
buildGetJobInstanceByIdReq(Long) - Static method in class org.springframework.yarn.batch.repository.JobRepositoryRpcFactory
Builds request for getting a job instance by id.
buildGetJobInstanceReq(String, JobParameters) - Static method in class org.springframework.yarn.batch.repository.JobRepositoryRpcFactory
Builds request for getting a job instance.
buildGetJobInstancesReq(String, int, int) - Static method in class org.springframework.yarn.batch.repository.JobRepositoryRpcFactory
Builds request for getting a job instance by its name and paging info.
buildGetJobNamesReq() - Static method in class org.springframework.yarn.batch.repository.JobRepositoryRpcFactory
Builds request for getting a job names.
buildGetLastJobExecutionReq(JobInstance) - Static method in class org.springframework.yarn.batch.repository.JobRepositoryRpcFactory
Builds request for getting a last execution by a job instance.
buildGetStepExecutionReq(JobExecution, Long) - Static method in class org.springframework.yarn.batch.repository.JobRepositoryRpcFactory
Builds request for getting a step execution job execution and step execution id.
buildSaveExecutionContextReq(StepExecution) - Static method in class org.springframework.yarn.batch.repository.JobRepositoryRpcFactory
Builds request for saving execution context from a step execution.
buildSaveExecutionContextReq(JobExecution) - Static method in class org.springframework.yarn.batch.repository.JobRepositoryRpcFactory
Builds request for saving execution context from a job execution.
buildSaveJobExecutionReq(JobExecution) - Static method in class org.springframework.yarn.batch.repository.JobRepositoryRpcFactory
Builds request for saving a job execution.
buildSaveStepExecutionReq(StepExecution) - Static method in class org.springframework.yarn.batch.repository.JobRepositoryRpcFactory
Builds request for saving a step execution.
buildSynchronizeStatusReq(JobExecution) - Static method in class org.springframework.yarn.batch.repository.JobRepositoryRpcFactory
Builds request for synchronizing a job execution status.
buildUpdateExecutionContextReq(StepExecution) - Static method in class org.springframework.yarn.batch.repository.JobRepositoryRpcFactory
Builds request for updating execution context from a step execution.
buildUpdateExecutionContextReq(JobExecution) - Static method in class org.springframework.yarn.batch.repository.JobRepositoryRpcFactory
Builds request for updating execution context from a job execution.
buildUpdateJobExecutionReq(JobExecution) - Static method in class org.springframework.yarn.batch.repository.JobRepositoryRpcFactory
Builds request for updating a job execution.
buildUpdateStepExecutionReq(StepExecution) - Static method in class org.springframework.yarn.batch.repository.JobRepositoryRpcFactory
Builds request for updating a step execution.

C

checkResponseMayThrow(BaseResponseObject) - Method in class org.springframework.yarn.batch.repository.AbstractRemoteDao
Checks status of a response and throws an exception if response status message is set to 'error'.
clazz - Variable in class org.springframework.yarn.batch.repository.bindings.ExecutionContextType.ObjectEntry
 
close() - Method in class org.springframework.yarn.batch.item.HdfsFileSplitItemReader
 
commitCount - Variable in class org.springframework.yarn.batch.repository.bindings.StepExecutionType
 
CompositePartitionedStepExecutionStateListener - Class in org.springframework.yarn.batch.listener
Composite listener for handling partitioned step state events.
CompositePartitionedStepExecutionStateListener() - Constructor for class org.springframework.yarn.batch.listener.CompositePartitionedStepExecutionStateListener
 
convertException(Exception) - Method in class org.springframework.yarn.batch.repository.AbstractRemoteDao
Converts given exception to Spring dao exception.
convertExecutionContext(ExecutionContext) - Static method in class org.springframework.yarn.batch.repository.JobRepositoryRpcFactory
Converts a ExecutionContext to ExecutionContextType.
convertExecutionContextType(ExecutionContextType) - Static method in class org.springframework.yarn.batch.repository.JobRepositoryRpcFactory
Converts a ExecutionContextType to ExecutionContext.
convertJobExecutionType(JobExecution) - Static method in class org.springframework.yarn.batch.repository.JobRepositoryRpcFactory
Creates JobExecutionType from JobExecution.
convertJobExecutionType(JobExecution, StepExecution) - Static method in class org.springframework.yarn.batch.repository.JobRepositoryRpcFactory
Creates JobExecutionType from JobExecution.
convertJobExecutionType(JobExecutionType) - Static method in class org.springframework.yarn.batch.repository.JobRepositoryRpcFactory
Converts a JobExecutionType to JobExecution.
convertJobInstanceType(JobInstance) - Static method in class org.springframework.yarn.batch.repository.JobRepositoryRpcFactory
Converts a JobInstance to JobInstanceType.
convertJobInstanceType(JobInstanceType) - Static method in class org.springframework.yarn.batch.repository.JobRepositoryRpcFactory
Converts a JobInstanceType to JobInstance.
convertJobParameters(JobParameters) - Static method in class org.springframework.yarn.batch.repository.JobRepositoryRpcFactory
Converts a JobParameters to JobParametersType.
convertJobParametersType(JobParametersType) - Static method in class org.springframework.yarn.batch.repository.JobRepositoryRpcFactory
Converts a JobParametersType to JobParameters.
convertStepExecutionType(StepExecution) - Static method in class org.springframework.yarn.batch.repository.JobRepositoryRpcFactory
Creates StepExecutionType from StepExecution.
convertStepExecutionType(StepExecution, JobExecution) - Static method in class org.springframework.yarn.batch.repository.JobRepositoryRpcFactory
Creates StepExecutionType from StepExecution.
convertStepExecutionType(StepExecutionType) - Static method in class org.springframework.yarn.batch.repository.JobRepositoryRpcFactory
Converts a StepExecutionType to StepExecution.
count - Variable in class org.springframework.yarn.batch.repository.bindings.GetJobInstancesReq
 
createExecutionContextDao() - Method in class org.springframework.yarn.batch.repository.RemoteJobExplorerFactoryBean
 
createExecutionContextDao() - Method in class org.springframework.yarn.batch.repository.RemoteJobRepositoryFactoryBean
 
createJobExecutionDao() - Method in class org.springframework.yarn.batch.repository.RemoteJobExplorerFactoryBean
 
createJobExecutionDao() - Method in class org.springframework.yarn.batch.repository.RemoteJobRepositoryFactoryBean
 
createJobInstance(String, JobParameters) - Method in class org.springframework.yarn.batch.repository.RemoteJobInstanceDao
 
createJobInstanceDao() - Method in class org.springframework.yarn.batch.repository.RemoteJobExplorerFactoryBean
 
createJobInstanceDao() - Method in class org.springframework.yarn.batch.repository.RemoteJobRepositoryFactoryBean
 
CreateJobInstanceReq - Class in org.springframework.yarn.batch.repository.bindings
 
CreateJobInstanceReq() - Constructor for class org.springframework.yarn.batch.repository.bindings.CreateJobInstanceReq
 
CreateJobInstanceRes - Class in org.springframework.yarn.batch.repository.bindings
Response for creating a job instance.
CreateJobInstanceRes() - Constructor for class org.springframework.yarn.batch.repository.bindings.CreateJobInstanceRes
 
CreateJobInstanceRes(JobInstanceType) - Constructor for class org.springframework.yarn.batch.repository.bindings.CreateJobInstanceRes
 
createResourceRequestData(Set<StepExecution>) - Method in class org.springframework.yarn.batch.partition.AbstractBatchPartitionHandler
Subclass may override this method to assign a specific ContainerRequestHint to a StepExecution.
createResourceRequestData(Set<StepExecution>) - Method in class org.springframework.yarn.batch.partition.HdfsSplitBatchPartitionHandler
 
createStepExecutionDao() - Method in class org.springframework.yarn.batch.repository.RemoteJobExplorerFactoryBean
 
createStepExecutionDao() - Method in class org.springframework.yarn.batch.repository.RemoteJobRepositoryFactoryBean
 
createStepExecutionSplits(StepExecutionSplitter, StepExecution) - Method in class org.springframework.yarn.batch.partition.AbstractBatchPartitionHandler
 
createStepExecutionSplits(StepExecutionSplitter, StepExecution) - Method in class org.springframework.yarn.batch.partition.HdfsSplitBatchPartitionHandler
 
createStepExecutionSplits(StepExecutionSplitter, StepExecution) - Method in class org.springframework.yarn.batch.partition.StaticBatchPartitionHandler
 
createTime - Variable in class org.springframework.yarn.batch.repository.bindings.JobExecutionType
 

D

DefaultBatchYarnContainer - Class in org.springframework.yarn.batch.container
Default implementation of AbstractBatchYarnContainer to handle Spring Batch remote steps.
DefaultBatchYarnContainer() - Constructor for class org.springframework.yarn.batch.container.DefaultBatchYarnContainer
 
doStart() - Method in class org.springframework.yarn.batch.am.BatchAppmaster
 

E

endTime - Variable in class org.springframework.yarn.batch.repository.bindings.JobExecutionType
 
endTime - Variable in class org.springframework.yarn.batch.repository.bindings.StepExecutionType
 
executionContext - Variable in class org.springframework.yarn.batch.repository.bindings.GetExecutionContextRes
 
executionContext - Variable in class org.springframework.yarn.batch.repository.bindings.JobExecutionType
 
executionContext - Variable in class org.springframework.yarn.batch.repository.bindings.StepExecutionType
 
ExecutionContextType - Class in org.springframework.yarn.batch.repository.bindings
Binding for ExecutionContext.
ExecutionContextType() - Constructor for class org.springframework.yarn.batch.repository.bindings.ExecutionContextType
 
ExecutionContextType.ObjectEntry - Class in org.springframework.yarn.batch.repository.bindings
 
ExecutionContextType.ObjectEntry() - Constructor for class org.springframework.yarn.batch.repository.bindings.ExecutionContextType.ObjectEntry
 
ExecutionContextType.ObjectEntry(Object, String) - Constructor for class org.springframework.yarn.batch.repository.bindings.ExecutionContextType.ObjectEntry
 
executionId - Variable in class org.springframework.yarn.batch.repository.bindings.GetJobExecutionReq
 
exitStatus - Variable in class org.springframework.yarn.batch.repository.bindings.JobExecutionType
 
exitStatus - Variable in class org.springframework.yarn.batch.repository.bindings.StepExecutionType
 

F

filterCount - Variable in class org.springframework.yarn.batch.repository.bindings.StepExecutionType
 
findJobExecutions(JobInstance) - Method in class org.springframework.yarn.batch.repository.RemoteJobExecutionDao
 
FindJobExecutionsReq - Class in org.springframework.yarn.batch.repository.bindings
 
FindJobExecutionsReq() - Constructor for class org.springframework.yarn.batch.repository.bindings.FindJobExecutionsReq
 
FindJobExecutionsRes - Class in org.springframework.yarn.batch.repository.bindings
Response for finding a job executions.
FindJobExecutionsRes() - Constructor for class org.springframework.yarn.batch.repository.bindings.FindJobExecutionsRes
 
findRunningJobExecutions(String) - Method in class org.springframework.yarn.batch.repository.RemoteJobExecutionDao
 
FindRunningJobExecutionsReq - Class in org.springframework.yarn.batch.repository.bindings
 
FindRunningJobExecutionsReq() - Constructor for class org.springframework.yarn.batch.repository.bindings.FindRunningJobExecutionsReq
 
FindRunningJobExecutionsRes - Class in org.springframework.yarn.batch.repository.bindings
Response for finding a running job executions.
FindRunningJobExecutionsRes() - Constructor for class org.springframework.yarn.batch.repository.bindings.FindRunningJobExecutionsRes
 

G

get(BaseObject) - Method in class org.springframework.yarn.batch.repository.JobRepositoryRemoteService
Handles requests.
getAppmasterScOperations() - Method in class org.springframework.yarn.batch.repository.AbstractRemoteDao
Gets the AppmasterMindScOperations for this implementation.
getConfiguration() - Method in class org.springframework.yarn.batch.partition.HdfsSplitBatchPartitionHandler
Gets the Yarn configuration.
getContainerResolver() - Method in class org.springframework.yarn.batch.partition.AbstractBatchPartitionHandler
Gets the container resolver.
getExecutionContext(JobExecution) - Method in class org.springframework.yarn.batch.repository.RemoteExecutionContextDao
 
getExecutionContext(StepExecution) - Method in class org.springframework.yarn.batch.repository.RemoteExecutionContextDao
 
getExecutionContextDao() - Method in class org.springframework.yarn.batch.repository.RemoteJobRepositoryFactoryBean
 
GetExecutionContextReq - Class in org.springframework.yarn.batch.repository.bindings
 
GetExecutionContextReq() - Constructor for class org.springframework.yarn.batch.repository.bindings.GetExecutionContextReq
 
GetExecutionContextRes - Class in org.springframework.yarn.batch.repository.bindings
Response for getting execution context.
GetExecutionContextRes() - Constructor for class org.springframework.yarn.batch.repository.bindings.GetExecutionContextRes
 
getId() - Method in class org.springframework.yarn.batch.repository.bindings.SaveJobExecutionRes
 
getId() - Method in class org.springframework.yarn.batch.repository.bindings.SaveStepExecutionRes
 
getId() - Method in class org.springframework.yarn.batch.repository.bindings.UpdateStepExecutionRes
 
getInterceptors() - Method in class org.springframework.yarn.batch.repository.BatchAppmasterService
Exposes the interceptor list for subclasses.
getJobExecution(Long) - Method in class org.springframework.yarn.batch.repository.RemoteJobExecutionDao
 
getJobExecutionDao() - Method in class org.springframework.yarn.batch.repository.RemoteJobRepositoryFactoryBean
 
GetJobExecutionReq - Class in org.springframework.yarn.batch.repository.bindings
 
GetJobExecutionReq() - Constructor for class org.springframework.yarn.batch.repository.bindings.GetJobExecutionReq
 
GetJobExecutionRes - Class in org.springframework.yarn.batch.repository.bindings
Response for getting a job execution.
GetJobExecutionRes() - Constructor for class org.springframework.yarn.batch.repository.bindings.GetJobExecutionRes
 
getJobExplorer() - Method in class org.springframework.yarn.batch.container.AbstractBatchYarnContainer
Gets the job explorer.
getJobInstance() - Method in class org.springframework.yarn.batch.repository.bindings.CreateJobInstanceRes
 
getJobInstance() - Method in class org.springframework.yarn.batch.repository.bindings.GetJobInstanceByIdRes
 
getJobInstance() - Method in class org.springframework.yarn.batch.repository.bindings.GetJobInstanceRes
 
getJobInstance(String, JobParameters) - Method in class org.springframework.yarn.batch.repository.RemoteJobInstanceDao
 
getJobInstance(Long) - Method in class org.springframework.yarn.batch.repository.RemoteJobInstanceDao
 
getJobInstance(JobExecution) - Method in class org.springframework.yarn.batch.repository.RemoteJobInstanceDao
 
GetJobInstanceByIdReq - Class in org.springframework.yarn.batch.repository.bindings
 
GetJobInstanceByIdReq() - Constructor for class org.springframework.yarn.batch.repository.bindings.GetJobInstanceByIdReq
 
GetJobInstanceByIdRes - Class in org.springframework.yarn.batch.repository.bindings
Response for getting a job instance by id.
GetJobInstanceByIdRes() - Constructor for class org.springframework.yarn.batch.repository.bindings.GetJobInstanceByIdRes
 
GetJobInstanceByIdRes(JobInstanceType) - Constructor for class org.springframework.yarn.batch.repository.bindings.GetJobInstanceByIdRes
 
getJobInstanceDao() - Method in class org.springframework.yarn.batch.repository.RemoteJobRepositoryFactoryBean
 
GetJobInstanceReq - Class in org.springframework.yarn.batch.repository.bindings
 
GetJobInstanceReq() - Constructor for class org.springframework.yarn.batch.repository.bindings.GetJobInstanceReq
 
GetJobInstanceRes - Class in org.springframework.yarn.batch.repository.bindings
Response for getting a job instance.
GetJobInstanceRes() - Constructor for class org.springframework.yarn.batch.repository.bindings.GetJobInstanceRes
 
GetJobInstanceRes(JobInstanceType) - Constructor for class org.springframework.yarn.batch.repository.bindings.GetJobInstanceRes
 
getJobInstances() - Method in class org.springframework.yarn.batch.repository.bindings.GetJobInstancesRes
 
getJobInstances(String, int, int) - Method in class org.springframework.yarn.batch.repository.RemoteJobInstanceDao
 
GetJobInstancesReq - Class in org.springframework.yarn.batch.repository.bindings
 
GetJobInstancesReq() - Constructor for class org.springframework.yarn.batch.repository.bindings.GetJobInstancesReq
 
GetJobInstancesRes - Class in org.springframework.yarn.batch.repository.bindings
Response for getting a job instance.
GetJobInstancesRes() - Constructor for class org.springframework.yarn.batch.repository.bindings.GetJobInstancesRes
 
GetJobInstancesRes(List<JobInstanceType>) - Constructor for class org.springframework.yarn.batch.repository.bindings.GetJobInstancesRes
 
getJobLauncher() - Method in class org.springframework.yarn.batch.am.AbstractBatchAppmaster
Gets the job launcher.
getJobName() - Method in class org.springframework.yarn.batch.am.AbstractBatchAppmaster
Gets the job name.
getJobNames - Variable in class org.springframework.yarn.batch.repository.bindings.GetJobNamesRes
 
getJobNames() - Method in class org.springframework.yarn.batch.repository.bindings.GetJobNamesRes
 
getJobNames() - Method in class org.springframework.yarn.batch.repository.RemoteJobInstanceDao
 
GetJobNamesReq - Class in org.springframework.yarn.batch.repository.bindings
 
GetJobNamesReq() - Constructor for class org.springframework.yarn.batch.repository.bindings.GetJobNamesReq
 
GetJobNamesRes - Class in org.springframework.yarn.batch.repository.bindings
Response for getting a job instance.
GetJobNamesRes() - Constructor for class org.springframework.yarn.batch.repository.bindings.GetJobNamesRes
 
GetJobNamesRes(List<String>) - Constructor for class org.springframework.yarn.batch.repository.bindings.GetJobNamesRes
 
getJobParametersConverter() - Method in class org.springframework.yarn.batch.am.AbstractBatchAppmaster
Gets the job parameters converter.
getLastJobExecution(JobInstance) - Method in class org.springframework.yarn.batch.repository.RemoteJobExecutionDao
 
GetLastJobExecutionReq - Class in org.springframework.yarn.batch.repository.bindings
 
GetLastJobExecutionReq() - Constructor for class org.springframework.yarn.batch.repository.bindings.GetLastJobExecutionReq
 
GetLastJobExecutionRes - Class in org.springframework.yarn.batch.repository.bindings
Response for getting a last job execution.
GetLastJobExecutionRes() - Constructor for class org.springframework.yarn.batch.repository.bindings.GetLastJobExecutionRes
 
getObject() - Method in class org.springframework.yarn.batch.repository.RemoteJobExplorerFactoryBean
 
getStatus() - Method in class org.springframework.yarn.batch.repository.bindings.SynchronizeStatusRes
 
getStep(String) - Method in class org.springframework.yarn.batch.partition.BeanFactoryStepLocator
Look up a bean with the provided name of type Step.
getStepExecution() - Method in class org.springframework.yarn.batch.event.PartitionedStepExecutionEvent
Gets the step execution for this event.
getStepExecution(JobExecution, Long) - Method in class org.springframework.yarn.batch.repository.RemoteStepExecutionDao
 
getStepExecutionDao() - Method in class org.springframework.yarn.batch.repository.RemoteJobRepositoryFactoryBean
 
GetStepExecutionReq - Class in org.springframework.yarn.batch.repository.bindings
 
GetStepExecutionReq() - Constructor for class org.springframework.yarn.batch.repository.bindings.GetStepExecutionReq
 
GetStepExecutionRes - Class in org.springframework.yarn.batch.repository.bindings
Response for getting a last job execution.
GetStepExecutionRes() - Constructor for class org.springframework.yarn.batch.repository.bindings.GetStepExecutionRes
 
getStepExecutions() - Method in class org.springframework.yarn.batch.am.AbstractBatchAppmaster
Gets the step executions.
getStepLocator() - Method in class org.springframework.yarn.batch.container.AbstractBatchYarnContainer
Gets the step locator.
getStepName() - Method in class org.springframework.yarn.batch.partition.AbstractBatchPartitionHandler
Gets the step name.
getStepNames() - Method in class org.springframework.yarn.batch.partition.BeanFactoryStepLocator
Look in the bean factory for all beans of type Step.
getVersion() - Method in class org.springframework.yarn.batch.repository.bindings.SaveJobExecutionRes
 
getVersion() - Method in class org.springframework.yarn.batch.repository.bindings.SaveStepExecutionRes
 
getVersion() - Method in class org.springframework.yarn.batch.repository.bindings.SynchronizeStatusRes
 
getVersion() - Method in class org.springframework.yarn.batch.repository.bindings.UpdateJobExecutionRes
 
getVersion() - Method in class org.springframework.yarn.batch.repository.bindings.UpdateStepExecutionRes
 

H

handle(StepExecutionSplitter, StepExecution) - Method in class org.springframework.yarn.batch.partition.AbstractBatchPartitionHandler
 
handleMindMessageInternal(MindRpcMessageHolder) - Method in class org.springframework.yarn.batch.repository.BatchAppmasterService
 
handleRequest(BaseObject) - Method in class org.springframework.yarn.batch.repository.BatchAppmasterService.JobRepositoryServiceInterceptorList
Handles the handleRequest calls.
handleRequest(BaseObject) - Method in interface org.springframework.yarn.batch.repository.JobRepositoryRemoteServiceInterceptor
Handles request if at least one interceptor returned null from a JobRepositoryRemoteServiceInterceptor.preRequest(BaseObject) method.
HdfsFileSplitItemReader<T> - Class in org.springframework.yarn.batch.item
Implementation of ItemReader able to read items from HDFS file splits.
HdfsFileSplitItemReader() - Constructor for class org.springframework.yarn.batch.item.HdfsFileSplitItemReader
Instantiates a new hdfs file split item reader.
HdfsSplitBatchPartitionHandler - Class in org.springframework.yarn.batch.partition
Implementation of Spring Batch PartitionHandler which does partitioning based on number of input files from HDFS.
HdfsSplitBatchPartitionHandler(AbstractBatchAppmaster) - Constructor for class org.springframework.yarn.batch.partition.HdfsSplitBatchPartitionHandler
Instantiates a new hdfs split batch partition handler.
HdfsSplitBatchPartitionHandler(AbstractBatchAppmaster, Configuration) - Constructor for class org.springframework.yarn.batch.partition.HdfsSplitBatchPartitionHandler
Instantiates a new hdfs split batch partition handler.

I

id - Variable in class org.springframework.yarn.batch.repository.bindings.GetJobInstanceByIdReq
 
id - Variable in class org.springframework.yarn.batch.repository.bindings.JobExecutionType
 
id - Variable in class org.springframework.yarn.batch.repository.bindings.JobInstanceType
 
id - Variable in class org.springframework.yarn.batch.repository.bindings.SaveJobExecutionRes
 
id - Variable in class org.springframework.yarn.batch.repository.bindings.SaveStepExecutionRes
 
id - Variable in class org.springframework.yarn.batch.repository.bindings.StepExecutionType
 
id - Variable in class org.springframework.yarn.batch.repository.bindings.UpdateStepExecutionRes
 
init() - Method in class org.springframework.yarn.batch.config.BatchNamespaceHandler
 
isSaveState() - Method in class org.springframework.yarn.batch.item.HdfsFileSplitItemReader
The flag that determines whether to save internal state for restarts.

J

jobExecution - Variable in class org.springframework.yarn.batch.repository.bindings.AddStepExecutionsReq
 
jobExecution - Variable in class org.springframework.yarn.batch.repository.bindings.AddStepExecutionsRes
 
jobExecution - Variable in class org.springframework.yarn.batch.repository.bindings.GetExecutionContextReq
 
jobExecution - Variable in class org.springframework.yarn.batch.repository.bindings.GetJobExecutionRes
 
jobExecution - Variable in class org.springframework.yarn.batch.repository.bindings.GetLastJobExecutionRes
 
jobExecution - Variable in class org.springframework.yarn.batch.repository.bindings.GetStepExecutionReq
 
jobExecution - Variable in class org.springframework.yarn.batch.repository.bindings.SaveExecutionContextReq
 
jobExecution - Variable in class org.springframework.yarn.batch.repository.bindings.SaveJobExecutionReq
 
jobExecution - Variable in class org.springframework.yarn.batch.repository.bindings.StepExecutionType
 
jobExecution - Variable in class org.springframework.yarn.batch.repository.bindings.SynchronizeStatusReq
 
jobExecution - Variable in class org.springframework.yarn.batch.repository.bindings.UpdateExecutionContextReq
 
jobExecution - Variable in class org.springframework.yarn.batch.repository.bindings.UpdateJobExecutionReq
 
jobExecutions - Variable in class org.springframework.yarn.batch.repository.bindings.FindJobExecutionsRes
 
jobExecutions - Variable in class org.springframework.yarn.batch.repository.bindings.FindRunningJobExecutionsRes
 
JobExecutionType - Class in org.springframework.yarn.batch.repository.bindings
Bindings for JobExecution.
JobExecutionType() - Constructor for class org.springframework.yarn.batch.repository.bindings.JobExecutionType
 
jobInstance - Variable in class org.springframework.yarn.batch.repository.bindings.CreateJobInstanceRes
 
jobInstance - Variable in class org.springframework.yarn.batch.repository.bindings.FindJobExecutionsReq
 
jobInstance - Variable in class org.springframework.yarn.batch.repository.bindings.GetJobInstanceByIdRes
 
jobInstance - Variable in class org.springframework.yarn.batch.repository.bindings.GetJobInstanceRes
 
jobInstance - Variable in class org.springframework.yarn.batch.repository.bindings.GetLastJobExecutionReq
 
jobInstance - Variable in class org.springframework.yarn.batch.repository.bindings.JobExecutionType
 
jobInstances - Variable in class org.springframework.yarn.batch.repository.bindings.GetJobInstancesRes
 
JobInstanceType - Class in org.springframework.yarn.batch.repository.bindings
 
JobInstanceType() - Constructor for class org.springframework.yarn.batch.repository.bindings.JobInstanceType
 
jobName - Variable in class org.springframework.yarn.batch.repository.bindings.CreateJobInstanceReq
 
jobName - Variable in class org.springframework.yarn.batch.repository.bindings.FindRunningJobExecutionsReq
 
jobName - Variable in class org.springframework.yarn.batch.repository.bindings.GetJobInstanceReq
 
jobName - Variable in class org.springframework.yarn.batch.repository.bindings.GetJobInstancesReq
 
jobName - Variable in class org.springframework.yarn.batch.repository.bindings.JobInstanceType
 
jobParameters - Variable in class org.springframework.yarn.batch.repository.bindings.CreateJobInstanceReq
 
jobParameters - Variable in class org.springframework.yarn.batch.repository.bindings.GetJobInstanceReq
 
jobParameters - Variable in class org.springframework.yarn.batch.repository.bindings.JobExecutionType
 
JobParametersType - Class in org.springframework.yarn.batch.repository.bindings
 
JobParametersType() - Constructor for class org.springframework.yarn.batch.repository.bindings.JobParametersType
 
JobParameterType - Class in org.springframework.yarn.batch.repository.bindings
 
JobParameterType() - Constructor for class org.springframework.yarn.batch.repository.bindings.JobParameterType
 
JobRepositoryRemoteService - Class in org.springframework.yarn.batch.repository
Service class handling remote operations for Spring Batch job repository.
JobRepositoryRemoteService() - Constructor for class org.springframework.yarn.batch.repository.JobRepositoryRemoteService
 
JobRepositoryRemoteServiceInterceptor - Interface in org.springframework.yarn.batch.repository
Interface for interceptors that are able to view and/or modify the messages when communication is handled with a service operating with BaseObject and BaseResponseObject.
JobRepositoryRpcFactory - Class in org.springframework.yarn.batch.repository
Helper class providing factory methods for building requests used in remote job repository functionality.
JobRepositoryRpcFactory() - Constructor for class org.springframework.yarn.batch.repository.JobRepositoryRpcFactory
 

L

lastUpdated - Variable in class org.springframework.yarn.batch.repository.bindings.JobExecutionType
 
lastUpdated - Variable in class org.springframework.yarn.batch.repository.bindings.StepExecutionType
 
LineDataMapper<T> - Interface in org.springframework.yarn.batch.item
Interface for mapping lines (strings) to domain objects.

M

map - Variable in class org.springframework.yarn.batch.repository.bindings.ExecutionContextType
 
mapLine(String) - Method in interface org.springframework.yarn.batch.item.LineDataMapper
Implementations must implement this method to map the provided line to the parameter type T.
mapLine(String) - Method in class org.springframework.yarn.batch.item.PassThroughLineDataMapper
 
message - Variable in class org.springframework.yarn.batch.repository.bindings.UpdateExecutionContextRes
 
MultiHdfsResourcePartitioner - Class in org.springframework.yarn.batch.partition
Implementation of Partitioner that locates multiple resources and associates their file names with execution context keys.
MultiHdfsResourcePartitioner() - Constructor for class org.springframework.yarn.batch.partition.MultiHdfsResourcePartitioner
 

O

obj - Variable in class org.springframework.yarn.batch.repository.bindings.ExecutionContextType.ObjectEntry
 
onContainerAllocated(Container) - Method in class org.springframework.yarn.batch.am.AbstractBatchAppmaster
 
onContainerCompleted(ContainerStatus) - Method in class org.springframework.yarn.batch.am.AbstractBatchAppmaster
 
onContainerLaunched(Container) - Method in class org.springframework.yarn.batch.am.AbstractBatchAppmaster
 
onInit() - Method in class org.springframework.yarn.batch.am.AbstractBatchAppmaster
 
open(ExecutionContext) - Method in class org.springframework.yarn.batch.item.HdfsFileSplitItemReader
 
org.springframework.yarn.batch.am - package org.springframework.yarn.batch.am
 
org.springframework.yarn.batch.config - package org.springframework.yarn.batch.config
 
org.springframework.yarn.batch.container - package org.springframework.yarn.batch.container
 
org.springframework.yarn.batch.event - package org.springframework.yarn.batch.event
 
org.springframework.yarn.batch.item - package org.springframework.yarn.batch.item
 
org.springframework.yarn.batch.listener - package org.springframework.yarn.batch.listener
 
org.springframework.yarn.batch.partition - package org.springframework.yarn.batch.partition
 
org.springframework.yarn.batch.repository - package org.springframework.yarn.batch.repository
 
org.springframework.yarn.batch.repository.bindings - package org.springframework.yarn.batch.repository.bindings
 

P

parameter - Variable in class org.springframework.yarn.batch.repository.bindings.JobParameterType
 
parameters - Variable in class org.springframework.yarn.batch.repository.bindings.JobParametersType
 
parameterType - Variable in class org.springframework.yarn.batch.repository.bindings.JobParameterType
 
parseInternal(Element, ParserContext) - Method in class org.springframework.yarn.batch.config.BatchMasterParser
 
partition(int) - Method in class org.springframework.yarn.batch.partition.MultiHdfsResourcePartitioner
Assign the filename of each of the injected resources to an ExecutionContext.
PartitionedStepExecutionEvent - Class in org.springframework.yarn.batch.event
Generic event representing that partitioned StepExecution state has been changed.
PartitionedStepExecutionEvent(Object, StepExecution) - Constructor for class org.springframework.yarn.batch.event.PartitionedStepExecutionEvent
Constructs event with the given StepExecution.
PartitionedStepExecutionStateListener - Interface in org.springframework.yarn.batch.listener
Interface used for partitioned step to notify its state.
PartitionedStepExecutionStateListener.PartitionedStepExecutionState - Enum in org.springframework.yarn.batch.listener
Enum for partitioned step states
PartitionedStepExecutionStatusReq - Class in org.springframework.yarn.batch.repository.bindings
Request binding used to notify status of remote step execution.
PartitionedStepExecutionStatusReq() - Constructor for class org.springframework.yarn.batch.repository.bindings.PartitionedStepExecutionStatusReq
 
PartitionedStepExecutionStatusRes - Class in org.springframework.yarn.batch.repository.bindings
Simple reply for PartitionedStepExecutionStatusReq.
PartitionedStepExecutionStatusRes() - Constructor for class org.springframework.yarn.batch.repository.bindings.PartitionedStepExecutionStatusRes
 
PassThroughLineDataMapper - Class in org.springframework.yarn.batch.item
Simple LineDataMapper implementation which just passes data as it is.
PassThroughLineDataMapper() - Constructor for class org.springframework.yarn.batch.item.PassThroughLineDataMapper
 
postRequest(BaseResponseObject) - Method in class org.springframework.yarn.batch.repository.BatchAppmasterService.JobRepositoryServiceInterceptorList
Handles he post request calls.
postRequest(BaseResponseObject) - Method in interface org.springframework.yarn.batch.repository.JobRepositoryRemoteServiceInterceptor
Invoked after request is made using BaseObject and before BaseResponseObject is sent to further processing.
preLaunch(Container, ContainerLaunchContext) - Method in class org.springframework.yarn.batch.am.AbstractBatchAppmaster
 
preRequest(BaseObject) - Method in class org.springframework.yarn.batch.repository.BatchAppmasterService.JobRepositoryServiceInterceptorList
Handles the pre request calls.
preRequest(BaseObject) - Method in interface org.springframework.yarn.batch.repository.JobRepositoryRemoteServiceInterceptor
Invoked after request is made using BaseObject.
processSkipCount - Variable in class org.springframework.yarn.batch.repository.bindings.StepExecutionType
 

R

read() - Method in class org.springframework.yarn.batch.item.HdfsFileSplitItemReader
 
readCount - Variable in class org.springframework.yarn.batch.repository.bindings.StepExecutionType
 
readSkipCount - Variable in class org.springframework.yarn.batch.repository.bindings.StepExecutionType
 
RemoteExecutionContextDao - Class in org.springframework.yarn.batch.repository
Proxy implementation of ExecutionContextDao.
RemoteExecutionContextDao() - Constructor for class org.springframework.yarn.batch.repository.RemoteExecutionContextDao
 
RemoteExecutionContextDao(AppmasterMindScOperations) - Constructor for class org.springframework.yarn.batch.repository.RemoteExecutionContextDao
 
RemoteJobExecutionDao - Class in org.springframework.yarn.batch.repository
Proxy implementation of JobExecutionDao.
RemoteJobExecutionDao() - Constructor for class org.springframework.yarn.batch.repository.RemoteJobExecutionDao
 
RemoteJobExecutionDao(AppmasterMindScOperations) - Constructor for class org.springframework.yarn.batch.repository.RemoteJobExecutionDao
 
RemoteJobExplorerFactoryBean - Class in org.springframework.yarn.batch.repository
A FactoryBean that automates the creation of a SimpleJobExplorer using in-memory DAO implementations.
RemoteJobExplorerFactoryBean(RemoteJobRepositoryFactoryBean) - Constructor for class org.springframework.yarn.batch.repository.RemoteJobExplorerFactoryBean
Create an instance with the provided RemoteJobRepositoryFactoryBean as a source of Dao instances.
RemoteJobExplorerFactoryBean() - Constructor for class org.springframework.yarn.batch.repository.RemoteJobExplorerFactoryBean
Create a factory with no RemoteJobRepositoryFactoryBean.
RemoteJobInstanceDao - Class in org.springframework.yarn.batch.repository
Proxy implementation of JobInstanceDao.
RemoteJobInstanceDao() - Constructor for class org.springframework.yarn.batch.repository.RemoteJobInstanceDao
 
RemoteJobInstanceDao(AppmasterMindScOperations) - Constructor for class org.springframework.yarn.batch.repository.RemoteJobInstanceDao
 
RemoteJobRepositoryFactoryBean - Class in org.springframework.yarn.batch.repository
 
RemoteJobRepositoryFactoryBean() - Constructor for class org.springframework.yarn.batch.repository.RemoteJobRepositoryFactoryBean
 
RemoteJobRepositoryFactoryBean(PlatformTransactionManager) - Constructor for class org.springframework.yarn.batch.repository.RemoteJobRepositoryFactoryBean
 
RemoteStepExecutionDao - Class in org.springframework.yarn.batch.repository
Proxy implementation of StepExecutionDao.
RemoteStepExecutionDao() - Constructor for class org.springframework.yarn.batch.repository.RemoteStepExecutionDao
 
RemoteStepExecutionDao(AppmasterMindScOperations) - Constructor for class org.springframework.yarn.batch.repository.RemoteStepExecutionDao
 
resolveId(Element, AbstractBeanDefinition, ParserContext) - Method in class org.springframework.yarn.batch.config.BatchMasterParser
 
rollbackCount - Variable in class org.springframework.yarn.batch.repository.bindings.StepExecutionType
 
runInternal() - Method in class org.springframework.yarn.batch.container.DefaultBatchYarnContainer
 
runJob(Job) - Method in class org.springframework.yarn.batch.am.AbstractBatchAppmaster
Runs the given job.

S

saveExecutionContext(JobExecution) - Method in class org.springframework.yarn.batch.repository.RemoteExecutionContextDao
 
saveExecutionContext(StepExecution) - Method in class org.springframework.yarn.batch.repository.RemoteExecutionContextDao
 
SaveExecutionContextReq - Class in org.springframework.yarn.batch.repository.bindings
 
SaveExecutionContextReq() - Constructor for class org.springframework.yarn.batch.repository.bindings.SaveExecutionContextReq
 
SaveExecutionContextRes - Class in org.springframework.yarn.batch.repository.bindings
Response for saving execution context.
SaveExecutionContextRes() - Constructor for class org.springframework.yarn.batch.repository.bindings.SaveExecutionContextRes
 
saveExecutionContexts(Collection<StepExecution>) - Method in class org.springframework.yarn.batch.repository.RemoteExecutionContextDao
 
saveJobExecution(JobExecution) - Method in class org.springframework.yarn.batch.repository.RemoteJobExecutionDao
 
SaveJobExecutionReq - Class in org.springframework.yarn.batch.repository.bindings
 
SaveJobExecutionReq() - Constructor for class org.springframework.yarn.batch.repository.bindings.SaveJobExecutionReq
 
SaveJobExecutionRes - Class in org.springframework.yarn.batch.repository.bindings
Response for saving a job execution.
SaveJobExecutionRes() - Constructor for class org.springframework.yarn.batch.repository.bindings.SaveJobExecutionRes
 
saveStepExecution(StepExecution) - Method in class org.springframework.yarn.batch.repository.RemoteStepExecutionDao
 
SaveStepExecutionReq - Class in org.springframework.yarn.batch.repository.bindings
 
SaveStepExecutionReq() - Constructor for class org.springframework.yarn.batch.repository.bindings.SaveStepExecutionReq
 
SaveStepExecutionRes - Class in org.springframework.yarn.batch.repository.bindings
Response for saving step execution.
SaveStepExecutionRes() - Constructor for class org.springframework.yarn.batch.repository.bindings.SaveStepExecutionRes
 
SaveStepExecutionRes(Long, Integer) - Constructor for class org.springframework.yarn.batch.repository.bindings.SaveStepExecutionRes
 
saveStepExecutions(Collection<StepExecution>) - Method in class org.springframework.yarn.batch.repository.RemoteStepExecutionDao
 
set(List<JobRepositoryRemoteServiceInterceptor>) - Method in class org.springframework.yarn.batch.repository.BatchAppmasterService.JobRepositoryServiceInterceptorList
Sets the interceptors, clears any existing interceptors.
setApplicationContext(ApplicationContext) - Method in class org.springframework.yarn.batch.am.BatchAppmaster
 
setAppmasterScOperations(AppmasterMindScOperations) - Method in class org.springframework.yarn.batch.repository.AbstractRemoteDao
Sets the AppmasterMindScOperations for this implementation.
setAppmasterScOperations(AppmasterMindScOperations) - Method in class org.springframework.yarn.batch.repository.RemoteJobRepositoryFactoryBean
 
setBeanFactory(BeanFactory) - Method in class org.springframework.yarn.batch.partition.BeanFactoryStepLocator
 
setConfiguration(Configuration) - Method in class org.springframework.yarn.batch.partition.HdfsSplitBatchPartitionHandler
Sets the Yarn configuration.
setConfiguration(Configuration) - Method in class org.springframework.yarn.batch.partition.MultiHdfsResourcePartitioner
Sets the Yarn configuration.
setContainerResolver(ContainerResolver) - Method in class org.springframework.yarn.batch.partition.AbstractBatchPartitionHandler
Sets the container resolver.
setExecutionContextDao(ExecutionContextDao) - Method in class org.springframework.yarn.batch.repository.JobRepositoryRemoteService
Sets the ExecutionContextDao for this service class.
setForceSplit(boolean) - Method in class org.springframework.yarn.batch.partition.MultiHdfsResourcePartitioner
Sets the force split.
setGridSize(int) - Method in class org.springframework.yarn.batch.partition.StaticBatchPartitionHandler
Passed to the StepExecutionSplitter in the AbstractBatchPartitionHandler.handle(StepExecutionSplitter, StepExecution) method, instructing it how many StepExecution instances are required, ideally.
setInterceptors(List<JobRepositoryRemoteServiceInterceptor>) - Method in class org.springframework.yarn.batch.repository.BatchAppmasterService
Set the list of channel interceptors.
setJobExecutionDao(JobExecutionDao) - Method in class org.springframework.yarn.batch.repository.JobRepositoryRemoteService
Sets the JobExecutionDao for this service class.
setJobExplorer(JobExplorer) - Method in class org.springframework.yarn.batch.container.AbstractBatchYarnContainer
Sets the job explorer.
setJobInstanceDao(JobInstanceDao) - Method in class org.springframework.yarn.batch.repository.JobRepositoryRemoteService
Sets the JobInstanceDao for this service class.
setJobLauncher(JobLauncher) - Method in class org.springframework.yarn.batch.am.AbstractBatchAppmaster
Sets the job launcher.
setJobName(String) - Method in class org.springframework.yarn.batch.am.AbstractBatchAppmaster
Sets the job name.
setJobParametersConverter(JobParametersConverter) - Method in class org.springframework.yarn.batch.am.AbstractBatchAppmaster
Injection setter for JobParametersConverter.
setJobRepositoryRemoteService(JobRepositoryRemoteService) - Method in class org.springframework.yarn.batch.repository.BatchAppmasterService
Sets the job repository remote service.
setKeyFileName(String) - Method in class org.springframework.yarn.batch.partition.MultiHdfsResourcePartitioner
The name of the key for the file name in each ExecutionContext.
setKeySplitLength(String) - Method in class org.springframework.yarn.batch.partition.MultiHdfsResourcePartitioner
The name of the key for the file split length in each ExecutionContext.
setKeySplitStart(String) - Method in class org.springframework.yarn.batch.partition.MultiHdfsResourcePartitioner
The name of the key for the file split start in each ExecutionContext.
setLineDataMapper(LineDataMapper<T>) - Method in class org.springframework.yarn.batch.item.HdfsFileSplitItemReader
Sets the line data mapper.
setMapJobRepositoryFactoryBean(MapJobRepositoryFactoryBean) - Method in class org.springframework.yarn.batch.repository.JobRepositoryRemoteService
Sets the MapJobRepositoryFactoryBean for this service class.
setRepositoryFactory(RemoteJobRepositoryFactoryBean) - Method in class org.springframework.yarn.batch.repository.RemoteJobExplorerFactoryBean
The repository factory that can be used to create daos for the explorer.
setResource(Resource) - Method in class org.springframework.yarn.batch.item.HdfsFileSplitItemReader
 
setResources(Resource[]) - Method in class org.springframework.yarn.batch.partition.MultiHdfsResourcePartitioner
The resources to assign to each partition.
setSaveState(boolean) - Method in class org.springframework.yarn.batch.item.HdfsFileSplitItemReader
Set the flag that determines whether to save internal data for ExecutionContext.
setSplitFile(boolean) - Method in class org.springframework.yarn.batch.partition.MultiHdfsResourcePartitioner
Sets the flat indicating if file input should be split.
setSplitLength(long) - Method in class org.springframework.yarn.batch.item.HdfsFileSplitItemReader
Sets the split length.
setSplitSize(int) - Method in class org.springframework.yarn.batch.partition.MultiHdfsResourcePartitioner
Sets the input split size relative to block size of the HDFS file.
setSplitStart(long) - Method in class org.springframework.yarn.batch.item.HdfsFileSplitItemReader
Sets the split start.
setStepExecutionDao(StepExecutionDao) - Method in class org.springframework.yarn.batch.repository.JobRepositoryRemoteService
Sets the StepExecutionDao for this service class.
setStepLocator(StepLocator) - Method in class org.springframework.yarn.batch.container.AbstractBatchYarnContainer
Sets the step locator.
setStepName(String) - Method in class org.springframework.yarn.batch.partition.AbstractBatchPartitionHandler
Sets the step name.
setUsePath(boolean) - Method in class org.springframework.yarn.batch.partition.MultiHdfsResourcePartitioner
If set to true resource path is set using URL.getPath(), otherwise URL.toExternalForm() is used.
start - Variable in class org.springframework.yarn.batch.repository.bindings.GetJobInstancesReq
 
startTime - Variable in class org.springframework.yarn.batch.repository.bindings.JobExecutionType
 
startTime - Variable in class org.springframework.yarn.batch.repository.bindings.StepExecutionType
 
state(PartitionedStepExecutionStateListener.PartitionedStepExecutionState, StepExecution) - Method in class org.springframework.yarn.batch.listener.CompositePartitionedStepExecutionStateListener
 
state(PartitionedStepExecutionStateListener.PartitionedStepExecutionState, StepExecution) - Method in interface org.springframework.yarn.batch.listener.PartitionedStepExecutionStateListener
Invoked when partitioned step state is changing.
StaticBatchPartitionHandler - Class in org.springframework.yarn.batch.partition
Implementation of Spring Batch PartitionHandler which does partitioning based on static grid size.
StaticBatchPartitionHandler(AbstractBatchAppmaster) - Constructor for class org.springframework.yarn.batch.partition.StaticBatchPartitionHandler
Instantiates a new static batch partition handler.
StaticBatchPartitionHandler(AbstractBatchAppmaster, int) - Constructor for class org.springframework.yarn.batch.partition.StaticBatchPartitionHandler
Instantiates a new static batch partition handler.
status - Variable in class org.springframework.yarn.batch.repository.bindings.JobExecutionType
 
status - Variable in class org.springframework.yarn.batch.repository.bindings.StepExecutionType
 
status - Variable in class org.springframework.yarn.batch.repository.bindings.SynchronizeStatusRes
 
status - Variable in class org.springframework.yarn.batch.repository.bindings.UpdateExecutionContextRes
 
stepExecution - Variable in class org.springframework.yarn.batch.repository.bindings.GetExecutionContextReq
 
stepExecution - Variable in class org.springframework.yarn.batch.repository.bindings.GetStepExecutionRes
 
stepExecution - Variable in class org.springframework.yarn.batch.repository.bindings.PartitionedStepExecutionStatusReq
 
stepExecution - Variable in class org.springframework.yarn.batch.repository.bindings.SaveExecutionContextReq
 
stepExecution - Variable in class org.springframework.yarn.batch.repository.bindings.SaveStepExecutionReq
 
stepExecution - Variable in class org.springframework.yarn.batch.repository.bindings.UpdateExecutionContextReq
 
stepExecution - Variable in class org.springframework.yarn.batch.repository.bindings.UpdateStepExecutionReq
 
stepExecutionId - Variable in class org.springframework.yarn.batch.repository.bindings.GetStepExecutionReq
 
stepExecutions - Variable in class org.springframework.yarn.batch.repository.bindings.JobExecutionType
 
StepExecutionType - Class in org.springframework.yarn.batch.repository.bindings
 
StepExecutionType() - Constructor for class org.springframework.yarn.batch.repository.bindings.StepExecutionType
 
stepName - Variable in class org.springframework.yarn.batch.repository.bindings.StepExecutionType
 
submitApplication() - Method in class org.springframework.yarn.batch.am.BatchAppmaster
 
synchronizeStatus(JobExecution) - Method in class org.springframework.yarn.batch.repository.RemoteJobExecutionDao
 
SynchronizeStatusReq - Class in org.springframework.yarn.batch.repository.bindings
 
SynchronizeStatusReq() - Constructor for class org.springframework.yarn.batch.repository.bindings.SynchronizeStatusReq
 
SynchronizeStatusRes - Class in org.springframework.yarn.batch.repository.bindings
Response for synching status.
SynchronizeStatusRes() - Constructor for class org.springframework.yarn.batch.repository.bindings.SynchronizeStatusRes
 
SynchronizeStatusRes(Integer, BatchStatus) - Constructor for class org.springframework.yarn.batch.repository.bindings.SynchronizeStatusRes
 

T

terminateOnly - Variable in class org.springframework.yarn.batch.repository.bindings.StepExecutionType
 
toString() - Method in class org.springframework.yarn.batch.event.PartitionedStepExecutionEvent
 

U

update(ExecutionContext) - Method in class org.springframework.yarn.batch.item.HdfsFileSplitItemReader
 
updateExecutionContext(JobExecution) - Method in class org.springframework.yarn.batch.repository.RemoteExecutionContextDao
 
updateExecutionContext(StepExecution) - Method in class org.springframework.yarn.batch.repository.RemoteExecutionContextDao
 
UpdateExecutionContextReq - Class in org.springframework.yarn.batch.repository.bindings
 
UpdateExecutionContextReq() - Constructor for class org.springframework.yarn.batch.repository.bindings.UpdateExecutionContextReq
 
UpdateExecutionContextRes - Class in org.springframework.yarn.batch.repository.bindings
Response for saving execution context.
UpdateExecutionContextRes() - Constructor for class org.springframework.yarn.batch.repository.bindings.UpdateExecutionContextRes
 
updateJobExecution(JobExecution) - Method in class org.springframework.yarn.batch.repository.RemoteJobExecutionDao
 
UpdateJobExecutionReq - Class in org.springframework.yarn.batch.repository.bindings
 
UpdateJobExecutionReq() - Constructor for class org.springframework.yarn.batch.repository.bindings.UpdateJobExecutionReq
 
UpdateJobExecutionRes - Class in org.springframework.yarn.batch.repository.bindings
Response for updating job execution.
UpdateJobExecutionRes() - Constructor for class org.springframework.yarn.batch.repository.bindings.UpdateJobExecutionRes
 
UpdateJobExecutionRes(Integer) - Constructor for class org.springframework.yarn.batch.repository.bindings.UpdateJobExecutionRes
 
updateStepExecution(StepExecution) - Method in class org.springframework.yarn.batch.repository.RemoteStepExecutionDao
 
UpdateStepExecutionReq - Class in org.springframework.yarn.batch.repository.bindings
 
UpdateStepExecutionReq() - Constructor for class org.springframework.yarn.batch.repository.bindings.UpdateStepExecutionReq
 
UpdateStepExecutionRes - Class in org.springframework.yarn.batch.repository.bindings
Response for saving step execution.
UpdateStepExecutionRes() - Constructor for class org.springframework.yarn.batch.repository.bindings.UpdateStepExecutionRes
 
UpdateStepExecutionRes(Long, Integer) - Constructor for class org.springframework.yarn.batch.repository.bindings.UpdateStepExecutionRes
 

V

valueOf(String) - Static method in enum org.springframework.yarn.batch.listener.PartitionedStepExecutionStateListener.PartitionedStepExecutionState
Returns the enum constant of this type with the specified name.
values() - Static method in enum org.springframework.yarn.batch.listener.PartitionedStepExecutionStateListener.PartitionedStepExecutionState
Returns an array containing the constants of this enum type, in the order they are declared.
version - Variable in class org.springframework.yarn.batch.repository.bindings.JobExecutionType
 
version - Variable in class org.springframework.yarn.batch.repository.bindings.JobInstanceType
 
version - Variable in class org.springframework.yarn.batch.repository.bindings.SaveJobExecutionRes
 
version - Variable in class org.springframework.yarn.batch.repository.bindings.SaveStepExecutionRes
 
version - Variable in class org.springframework.yarn.batch.repository.bindings.StepExecutionType
 
version - Variable in class org.springframework.yarn.batch.repository.bindings.SynchronizeStatusRes
 
version - Variable in class org.springframework.yarn.batch.repository.bindings.UpdateJobExecutionRes
 
version - Variable in class org.springframework.yarn.batch.repository.bindings.UpdateStepExecutionRes
 

W

waitCompleteState(StepExecution) - Method in class org.springframework.yarn.batch.partition.AbstractBatchPartitionHandler
Uses CountDownLatch to wait completion status from application master.
writeCount - Variable in class org.springframework.yarn.batch.repository.bindings.StepExecutionType
 
writeSkipCount - Variable in class org.springframework.yarn.batch.repository.bindings.StepExecutionType
 

A B C D E F G H I J L M O P R S T U V W