Uses of Class
org.springframework.batch.integration.partition.RemotePartitioningManagerStepBuilder
Packages that use RemotePartitioningManagerStepBuilder
-
Uses of RemotePartitioningManagerStepBuilder in org.springframework.batch.integration.partition
Methods in org.springframework.batch.integration.partition that return RemotePartitioningManagerStepBuilderModifier and TypeMethodDescriptionRemotePartitioningManagerStepBuilder.aggregator(StepExecutionAggregator aggregator) RemotePartitioningManagerStepBuilder.allowStartIfComplete(boolean allowStartIfComplete) RemotePartitioningManagerStepBuilder.beanFactory(org.springframework.beans.factory.BeanFactory beanFactory) Set the bean factory.Creates aRemotePartitioningManagerStepBuilderand initializes its job repository, job explorer, bean factory and transaction manager.RemotePartitioningManagerStepBuilder.gridSize(int gridSize) RemotePartitioningManagerStepBuilder.inputChannel(org.springframework.messaging.MessageChannel inputChannel) Set the input channel on which replies from workers will be received.RemotePartitioningManagerStepBuilder.jobExplorer(JobExplorer jobExplorer) Set the job explorer.RemotePartitioningManagerStepBuilder.listener(StepExecutionListener listener) RemotePartitioningManagerStepBuilder.messagingTemplate(org.springframework.integration.core.MessagingTemplate messagingTemplate) Set theMessagingTemplateto use to send data to workers.RemotePartitioningManagerStepBuilder.outputChannel(org.springframework.messaging.MessageChannel outputChannel) Set the output channel on which requests to workers will be sent.RemotePartitioningManagerStepBuilder.partitioner(String workerStepName, Partitioner partitioner) RemotePartitioningManagerStepBuilder.partitionHandler(PartitionHandler partitionHandler) This method will throw aUnsupportedOperationExceptionsince the partition handler of the manager step will be automatically set to an instance ofMessageChannelPartitionHandler.RemotePartitioningManagerStepBuilder.pollInterval(long pollInterval) How often to poll the job repository for the status of the workers.RemotePartitioningManagerStepBuilder.repository(JobRepository jobRepository) RemotePartitioningManagerStepBuilder.splitter(StepExecutionSplitter splitter) RemotePartitioningManagerStepBuilder.startLimit(int startLimit) RemotePartitioningManagerStepBuilder.timeout(long timeout) When using job repository polling, the time limit to wait.