public class RemotePartitioningManagerStepBuilder
extends org.springframework.batch.core.step.builder.PartitionStepBuilder
MessageChannelPartitionHandler on the manager step.
If no messagingTemplate is provided through
messagingTemplate(MessagingTemplate),
this builder will create one and set its default channel to the outputChannel
provided through outputChannel(MessageChannel).
If a messagingTemplate is provided, it is assumed that it is fully configured
and that its default channel is set to an output channel on which requests to workers
will be sent.
| Constructor and Description |
|---|
RemotePartitioningManagerStepBuilder(java.lang.String stepName)
Create a new
RemotePartitioningManagerStepBuilder. |
| Modifier and Type | Method and Description |
|---|---|
RemotePartitioningManagerStepBuilder |
aggregator(org.springframework.batch.core.partition.support.StepExecutionAggregator aggregator) |
RemotePartitioningManagerStepBuilder |
allowStartIfComplete(boolean allowStartIfComplete) |
RemotePartitioningManagerStepBuilder |
beanFactory(org.springframework.beans.factory.BeanFactory beanFactory)
Set the bean factory.
|
org.springframework.batch.core.Step |
build() |
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(org.springframework.batch.core.explore.JobExplorer jobExplorer)
Set the job explorer.
|
RemotePartitioningManagerStepBuilder |
listener(java.lang.Object listener) |
RemotePartitioningManagerStepBuilder |
listener(org.springframework.batch.core.StepExecutionListener listener) |
RemotePartitioningManagerStepBuilder |
messagingTemplate(org.springframework.integration.core.MessagingTemplate messagingTemplate)
Set the
MessagingTemplate 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(java.lang.String workerStepName,
org.springframework.batch.core.partition.support.Partitioner partitioner) |
RemotePartitioningManagerStepBuilder |
partitionHandler(org.springframework.batch.core.partition.PartitionHandler partitionHandler)
This method will throw a
UnsupportedOperationException since
the partition handler of the manager step will be automatically set to an
instance of MessageChannelPartitionHandler. |
RemotePartitioningManagerStepBuilder |
pollInterval(long pollInterval)
How often to poll the job repository for the status of the workers.
|
RemotePartitioningManagerStepBuilder |
repository(org.springframework.batch.core.repository.JobRepository jobRepository) |
RemotePartitioningManagerStepBuilder |
splitter(org.springframework.batch.core.partition.StepExecutionSplitter splitter) |
RemotePartitioningManagerStepBuilder |
startLimit(int startLimit) |
RemotePartitioningManagerStepBuilder |
step(org.springframework.batch.core.Step step) |
RemotePartitioningManagerStepBuilder |
timeout(long timeout)
When using job repository polling, the time limit to wait.
|
RemotePartitioningManagerStepBuilder |
transactionManager(org.springframework.transaction.PlatformTransactionManager transactionManager) |
getAggregator, getGridSize, getPartitioner, getPartitionHandler, getSplitter, getStep, getStepName, getTaskExecutor, taskExecutorpublic RemotePartitioningManagerStepBuilder(java.lang.String stepName)
RemotePartitioningManagerStepBuilder.stepName - name of the manager steppublic RemotePartitioningManagerStepBuilder inputChannel(org.springframework.messaging.MessageChannel inputChannel)
inputChannel - the input channelpublic RemotePartitioningManagerStepBuilder outputChannel(org.springframework.messaging.MessageChannel outputChannel)
Use either this setter or messagingTemplate(MessagingTemplate)
to provide a fully configured messaging template.
outputChannel - the output channel.messagingTemplate(MessagingTemplate)public RemotePartitioningManagerStepBuilder messagingTemplate(org.springframework.integration.core.MessagingTemplate messagingTemplate)
MessagingTemplate to use to send data to workers.
The default channel of the messaging template must be set.
Use either this setter to provide a fully configured messaging template or
provide an output channel through outputChannel(MessageChannel)
and a default messaging template will be created.
messagingTemplate - the messaging template to useoutputChannel(MessageChannel)public RemotePartitioningManagerStepBuilder jobExplorer(org.springframework.batch.core.explore.JobExplorer jobExplorer)
jobExplorer - the job explorer to use.public RemotePartitioningManagerStepBuilder pollInterval(long pollInterval)
pollInterval - the poll interval value in millisecondspublic RemotePartitioningManagerStepBuilder timeout(long timeout)
timeout - the timeout value in millisecondspublic RemotePartitioningManagerStepBuilder beanFactory(org.springframework.beans.factory.BeanFactory beanFactory)
beanFactory - the bean factory to usepublic org.springframework.batch.core.Step build()
build in class org.springframework.batch.core.step.builder.PartitionStepBuilderpublic RemotePartitioningManagerStepBuilder repository(org.springframework.batch.core.repository.JobRepository jobRepository)
repository in class org.springframework.batch.core.step.builder.StepBuilderHelper<org.springframework.batch.core.step.builder.PartitionStepBuilder>public RemotePartitioningManagerStepBuilder transactionManager(org.springframework.transaction.PlatformTransactionManager transactionManager)
transactionManager in class org.springframework.batch.core.step.builder.StepBuilderHelper<org.springframework.batch.core.step.builder.PartitionStepBuilder>public RemotePartitioningManagerStepBuilder partitioner(java.lang.String workerStepName, org.springframework.batch.core.partition.support.Partitioner partitioner)
partitioner in class org.springframework.batch.core.step.builder.PartitionStepBuilderpublic RemotePartitioningManagerStepBuilder gridSize(int gridSize)
gridSize in class org.springframework.batch.core.step.builder.PartitionStepBuilderpublic RemotePartitioningManagerStepBuilder step(org.springframework.batch.core.Step step)
step in class org.springframework.batch.core.step.builder.PartitionStepBuilderpublic RemotePartitioningManagerStepBuilder splitter(org.springframework.batch.core.partition.StepExecutionSplitter splitter)
splitter in class org.springframework.batch.core.step.builder.PartitionStepBuilderpublic RemotePartitioningManagerStepBuilder aggregator(org.springframework.batch.core.partition.support.StepExecutionAggregator aggregator)
aggregator in class org.springframework.batch.core.step.builder.PartitionStepBuilderpublic RemotePartitioningManagerStepBuilder startLimit(int startLimit)
startLimit in class org.springframework.batch.core.step.builder.StepBuilderHelper<org.springframework.batch.core.step.builder.PartitionStepBuilder>public RemotePartitioningManagerStepBuilder listener(java.lang.Object listener)
listener in class org.springframework.batch.core.step.builder.StepBuilderHelper<org.springframework.batch.core.step.builder.PartitionStepBuilder>public RemotePartitioningManagerStepBuilder listener(org.springframework.batch.core.StepExecutionListener listener)
listener in class org.springframework.batch.core.step.builder.StepBuilderHelper<org.springframework.batch.core.step.builder.PartitionStepBuilder>public RemotePartitioningManagerStepBuilder allowStartIfComplete(boolean allowStartIfComplete)
allowStartIfComplete in class org.springframework.batch.core.step.builder.StepBuilderHelper<org.springframework.batch.core.step.builder.PartitionStepBuilder>public RemotePartitioningManagerStepBuilder partitionHandler(org.springframework.batch.core.partition.PartitionHandler partitionHandler) throws java.lang.UnsupportedOperationException
UnsupportedOperationException since
the partition handler of the manager step will be automatically set to an
instance of MessageChannelPartitionHandler.
When building a manager step for remote partitioning using this builder,
no partition handler must be provided.partitionHandler in class org.springframework.batch.core.step.builder.PartitionStepBuilderpartitionHandler - a partition handlerjava.lang.UnsupportedOperationException - if a partition handler is provided