- SEC_SPEL_KEY_FILENAME - Static variable in class org.springframework.yarn.batch.BatchSystemConstants
-
Default spel expression for step execution context file name
- SEC_SPEL_KEY_SPLITLENGTH - Static variable in class org.springframework.yarn.batch.BatchSystemConstants
-
Default spel expression for step execution context file split length
- SEC_SPEL_KEY_SPLITSTART - Static variable in class org.springframework.yarn.batch.BatchSystemConstants
-
Default spel expression for step execution context file split start position
- set(List<JobRepositoryRemoteServiceInterceptor>) - Method in class org.springframework.yarn.batch.repository.BatchAppmasterService.JobRepositoryServiceInterceptorList
-
Sets the interceptors, clears any existing interceptors.
- setApplicationEventPublisher(ApplicationEventPublisher) - Method in class org.springframework.yarn.batch.support.YarnJobLauncher
-
- setAppmasterScOperations(AppmasterMindScOperations) - Method in class org.springframework.yarn.batch.repository.AbstractRemoteDao
-
Sets the AppmasterMindScOperations for this implementation.
- setAppmasterServiceClient(AppmasterServiceClient) - Method in class org.springframework.yarn.batch.container.DefaultBatchYarnContainer
-
- setBatchAppmaster(BatchYarnAppmaster) - Method in class org.springframework.yarn.batch.partition.AbstractPartitionHandler
-
Sets the batch appmaster.
- setBeanFactory(BeanFactory) - Method in class org.springframework.yarn.batch.support.BeanFactoryStepLocator
-
- setConfiguration(Configuration) - Method in class org.springframework.yarn.batch.partition.AbstractPartitioner
-
Sets the hadoop configuration.
- setDataStoreReader(DataStoreReader<T>) - Method in class org.springframework.yarn.batch.item.DataStoreItemReader
-
Sets the data store reader.
- setEnabled(boolean) - Method in class org.springframework.yarn.batch.support.YarnBatchProperties.JobProperties
-
- setEnabled(boolean) - Method in class org.springframework.yarn.batch.support.YarnBatchProperties
-
- setFailNext(boolean) - Method in class org.springframework.yarn.batch.support.YarnBatchProperties.JobProperties
-
- setFailRestart(boolean) - Method in class org.springframework.yarn.batch.support.YarnBatchProperties.JobProperties
-
- setGridSize(int) - Method in class org.springframework.yarn.batch.partition.StaticPartitionHandler
-
- setInputPatterns(String) - Method in class org.springframework.yarn.batch.partition.SplitterPartitioner
-
Sets the input patterns.
- setInputPatterns(Set<String>) - Method in class org.springframework.yarn.batch.partition.SplitterPartitioner
-
Sets the input patterns.
- setInterceptors(List<JobRepositoryRemoteServiceInterceptor>) - Method in class org.springframework.yarn.batch.repository.BatchAppmasterService
-
Set the list of channel interceptors.
- setJobExplorer(JobExplorer) - Method in class org.springframework.yarn.batch.container.AbstractBatchYarnContainer
-
Sets the job explorer.
- setJobExplorer(JobExplorer) - Method in class org.springframework.yarn.batch.repository.JobRepositoryService
-
- setJobExplorer(JobExplorer) - Method in class org.springframework.yarn.batch.support.YarnJobLauncher
-
- setJobLauncher(JobLauncher) - Method in class org.springframework.yarn.batch.support.YarnJobLauncher
-
Sets the job launcher.
- setJobName(String) - Method in class org.springframework.yarn.batch.support.YarnJobLauncher
-
Sets the enabled job name.
- setJobParametersConverter(JobParametersConverter) - Method in class org.springframework.yarn.batch.support.YarnJobLauncher
-
- setJobRegistry(JobRegistry) - Method in class org.springframework.yarn.batch.support.YarnJobLauncher
-
- setJobRepository(JobRepository) - Method in class org.springframework.yarn.batch.repository.JobRepositoryService
-
- setJobRepositoryRemoteService(JobRepositoryService) - Method in class org.springframework.yarn.batch.repository.BatchAppmasterService
-
Sets the job repository remote service.
- setJobs(List<YarnBatchProperties.JobProperties>) - Method in class org.springframework.yarn.batch.support.YarnBatchProperties
-
- setJobs(Collection<Job>) - Method in class org.springframework.yarn.batch.support.YarnJobLauncher
-
Sets the jobs.
- setKeyFileName(String) - Method in class org.springframework.yarn.batch.partition.AbstractPartitioner
-
- setKeySplitLength(String) - Method in class org.springframework.yarn.batch.partition.AbstractPartitioner
-
- setKeySplitLocations(String) - Method in class org.springframework.yarn.batch.partition.AbstractPartitioner
-
- setKeySplitLocations(String) - Method in class org.springframework.yarn.batch.partition.AbstractPartitionHandler
-
- setKeySplitStart(String) - Method in class org.springframework.yarn.batch.partition.AbstractPartitioner
-
- setLineDataMapper(LineDataMapper<T>) - Method in class org.springframework.yarn.batch.item.DataStoreItemReader
-
Sets the line data mapper.
- setName(String) - Method in class org.springframework.yarn.batch.support.YarnBatchProperties.JobProperties
-
- setName(String) - Method in class org.springframework.yarn.batch.support.YarnBatchProperties
-
- setNext(boolean) - Method in class org.springframework.yarn.batch.support.YarnBatchProperties.JobProperties
-
- setParameters(Map<String, Object>) - Method in class org.springframework.yarn.batch.support.YarnBatchProperties.JobProperties
-
- setPartitionBaseIdentifier(String) - Method in class org.springframework.yarn.batch.partition.AbstractPartitioner
-
- setRestart(boolean) - Method in class org.springframework.yarn.batch.support.YarnBatchProperties.JobProperties
-
- setSaveState(boolean) - Method in class org.springframework.yarn.batch.item.DataStoreItemReader
-
Set the flag that determines whether to save internal data for
ExecutionContext.
- setSplitter(Splitter) - Method in class org.springframework.yarn.batch.partition.SplitterPartitioner
-
Sets the splitter.
- 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.AbstractPartitionHandler
-
Sets the remote step name.
- setTest(Map<YarnBatchProperties.Jobs2Enum, Object>) - Method in class org.springframework.yarn.batch.support.YarnBatchProperties
-
- setYarnAppmaster(YarnAppmaster) - Method in class org.springframework.yarn.batch.partition.AbstractPartitionHandler
-
Sets the batch appmaster.
- setYarnBatchProperties(YarnBatchProperties) - Method in class org.springframework.yarn.batch.support.YarnJobLauncher
-
- setYarnJobLauncher(YarnJobLauncher) - Method in class org.springframework.yarn.batch.am.AbstractBatchAppmaster
-
- SimpleYarnBatchConfiguration - Class in org.springframework.yarn.batch.config
-
Annotation based batch configuration for Yarn Appmaster.
- SimpleYarnBatchConfiguration() - Constructor for class org.springframework.yarn.batch.config.SimpleYarnBatchConfiguration
-
- SimpleYarnRemoteBatchConfiguration - Class in org.springframework.yarn.batch.config
-
Annotation based batch configuration for Yarn Container.
- SimpleYarnRemoteBatchConfiguration() - Constructor for class org.springframework.yarn.batch.config.SimpleYarnRemoteBatchConfiguration
-
- SplitterPartitioner - Class in org.springframework.yarn.batch.partition
-
Implementation of
Partitioner that locates multiple resources and
associates their file names with execution context keys.
- SplitterPartitioner() - Constructor for class org.springframework.yarn.batch.partition.SplitterPartitioner
-
- SplitterPartitionHandler - Class in org.springframework.yarn.batch.partition
-
Implementation of Spring Batch
PartitionHandler which does
partitioning based on number of input files from HDFS.
- SplitterPartitionHandler() - Constructor for class org.springframework.yarn.batch.partition.SplitterPartitionHandler
-
Instantiates a new splitter partition handler.
- SplitterPartitionHandler(AbstractBatchAppmaster) - Constructor for class org.springframework.yarn.batch.partition.SplitterPartitionHandler
-
Instantiates a new splitter partition handler.
- start - Variable in class org.springframework.yarn.batch.repository.bindings.exp.FindJobInstancesByJobNameReq
-
- start - Variable in class org.springframework.yarn.batch.repository.bindings.exp.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.
- StaticPartitionHandler - Class in org.springframework.yarn.batch.partition
-
Implementation of Spring Batch
PartitionHandler which does
partitioning based on static grid size.
- StaticPartitionHandler() - Constructor for class org.springframework.yarn.batch.partition.StaticPartitionHandler
-
Instantiates a new static partition handler.
- StaticPartitionHandler(BatchYarnAppmaster) - Constructor for class org.springframework.yarn.batch.partition.StaticPartitionHandler
-
Instantiates a new static partition handler.
- StaticPartitionHandler(BatchYarnAppmaster, int) - Constructor for class org.springframework.yarn.batch.partition.StaticPartitionHandler
-
Instantiates a new static partition handler.
- status - Variable in class org.springframework.yarn.batch.repository.bindings.JobExecutionType
-
- status - Variable in class org.springframework.yarn.batch.repository.bindings.repo.UpdateExecutionContextRes
-
- status - Variable in class org.springframework.yarn.batch.repository.bindings.StepExecutionType
-
- stepBuilders() - Method in class org.springframework.yarn.batch.config.SimpleYarnRemoteBatchConfiguration
-
- stepExecution - Variable in class org.springframework.yarn.batch.repository.bindings.exp.GetStepExecutionRes
-
- stepExecution - Variable in class org.springframework.yarn.batch.repository.bindings.PartitionedStepExecutionStatusReq
-
- stepExecution - Variable in class org.springframework.yarn.batch.repository.bindings.repo.AddWithStepExecutionReq
-
- stepExecution - Variable in class org.springframework.yarn.batch.repository.bindings.repo.GetLastStepExecutionRes
-
- stepExecution - Variable in class org.springframework.yarn.batch.repository.bindings.repo.UpdateExecutionContextReq
-
- stepExecution - Variable in class org.springframework.yarn.batch.repository.bindings.repo.UpdateWithStepExecutionReq
-
- stepExecutionId - Variable in class org.springframework.yarn.batch.repository.bindings.exp.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
-
- stepLocator() - Method in class org.springframework.yarn.batch.config.SimpleYarnRemoteBatchConfiguration
-
- stepName - Variable in class org.springframework.yarn.batch.repository.bindings.repo.GetLastStepExecutionReq
-
- stepName - Variable in class org.springframework.yarn.batch.repository.bindings.repo.GetStepExecutionCountReq
-
- stepName - Variable in class org.springframework.yarn.batch.repository.bindings.StepExecutionType
-
- submitApplication() - Method in class org.springframework.yarn.batch.am.BatchAppmaster
-