Uses of Class
org.springframework.batch.integration.partition.RemotePartitioningManagerStepBuilder
-
Uses of RemotePartitioningManagerStepBuilder in org.springframework.batch.integration.partition
Modifier and TypeMethodDescriptionRemotePartitioningManagerStepBuilder.aggregator
(StepExecutionAggregator aggregator) RemotePartitioningManagerStepBuilder.allowStartIfComplete
(boolean allowStartIfComplete) RemotePartitioningManagerStepBuilder.beanFactory
(org.springframework.beans.factory.BeanFactory beanFactory) Set the bean factory.Creates aRemotePartitioningManagerStepBuilder
and 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 theMessagingTemplate
to 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 aUnsupportedOperationException
since 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.