public class RemotePartitioningMasterStepBuilder
extends org.springframework.batch.core.step.builder.PartitionStepBuilder
MessageChannelPartitionHandler on the master 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 |
|---|
RemotePartitioningMasterStepBuilder(java.lang.String stepName)
Create a new
RemotePartitioningMasterStepBuilder. |
| Modifier and Type | Method and Description |
|---|---|
RemotePartitioningMasterStepBuilder |
aggregator(org.springframework.batch.core.partition.support.StepExecutionAggregator aggregator) |
RemotePartitioningMasterStepBuilder |
allowStartIfComplete(boolean allowStartIfComplete) |
RemotePartitioningMasterStepBuilder |
beanFactory(org.springframework.beans.factory.BeanFactory beanFactory)
Set the bean factory.
|
org.springframework.batch.core.Step |
build() |
RemotePartitioningMasterStepBuilder |
gridSize(int gridSize) |
RemotePartitioningMasterStepBuilder |
inputChannel(org.springframework.messaging.MessageChannel inputChannel)
Set the input channel on which replies from workers will be received.
|
RemotePartitioningMasterStepBuilder |
jobExplorer(org.springframework.batch.core.explore.JobExplorer jobExplorer)
Set the job explorer.
|
RemotePartitioningMasterStepBuilder |
listener(java.lang.Object listener) |
RemotePartitioningMasterStepBuilder |
listener(org.springframework.batch.core.StepExecutionListener listener) |
RemotePartitioningMasterStepBuilder |
messagingTemplate(org.springframework.integration.core.MessagingTemplate messagingTemplate)
Set the
MessagingTemplate to use to send data to workers. |
RemotePartitioningMasterStepBuilder |
outputChannel(org.springframework.messaging.MessageChannel outputChannel)
Set the output channel on which requests to workers will be sent.
|
RemotePartitioningMasterStepBuilder |
partitioner(java.lang.String slaveStepName,
org.springframework.batch.core.partition.support.Partitioner partitioner) |
RemotePartitioningMasterStepBuilder |
partitionHandler(org.springframework.batch.core.partition.PartitionHandler partitionHandler)
This method will throw a
UnsupportedOperationException since
the partition handler of the master step will be automatically set to an
instance of MessageChannelPartitionHandler. |
RemotePartitioningMasterStepBuilder |
pollInterval(long pollInterval)
How often to poll the job repository for the status of the workers.
|
RemotePartitioningMasterStepBuilder |
repository(org.springframework.batch.core.repository.JobRepository jobRepository) |
RemotePartitioningMasterStepBuilder |
splitter(org.springframework.batch.core.partition.StepExecutionSplitter splitter) |
RemotePartitioningMasterStepBuilder |
startLimit(int startLimit) |
RemotePartitioningMasterStepBuilder |
step(org.springframework.batch.core.Step step) |
RemotePartitioningMasterStepBuilder |
timeout(long timeout)
When using job repository polling, the time limit to wait.
|
RemotePartitioningMasterStepBuilder |
transactionManager(org.springframework.transaction.PlatformTransactionManager transactionManager) |
getAggregator, getGridSize, getPartitioner, getPartitionHandler, getSplitter, getStep, getStepName, getTaskExecutor, taskExecutorpublic RemotePartitioningMasterStepBuilder(java.lang.String stepName)
RemotePartitioningMasterStepBuilder.stepName - name of the master steppublic RemotePartitioningMasterStepBuilder inputChannel(org.springframework.messaging.MessageChannel inputChannel)
inputChannel - the input channelpublic RemotePartitioningMasterStepBuilder 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 RemotePartitioningMasterStepBuilder 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 RemotePartitioningMasterStepBuilder jobExplorer(org.springframework.batch.core.explore.JobExplorer jobExplorer)
jobExplorer - the job explorer to use.public RemotePartitioningMasterStepBuilder pollInterval(long pollInterval)
pollInterval - the poll interval value in millisecondspublic RemotePartitioningMasterStepBuilder timeout(long timeout)
timeout - the timeout value in millisecondspublic RemotePartitioningMasterStepBuilder 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 RemotePartitioningMasterStepBuilder 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 RemotePartitioningMasterStepBuilder transactionManager(org.springframework.transaction.PlatformTransactionManager transactionManager)
transactionManager in class org.springframework.batch.core.step.builder.StepBuilderHelper<org.springframework.batch.core.step.builder.PartitionStepBuilder>public RemotePartitioningMasterStepBuilder partitioner(java.lang.String slaveStepName, org.springframework.batch.core.partition.support.Partitioner partitioner)
partitioner in class org.springframework.batch.core.step.builder.PartitionStepBuilderpublic RemotePartitioningMasterStepBuilder gridSize(int gridSize)
gridSize in class org.springframework.batch.core.step.builder.PartitionStepBuilderpublic RemotePartitioningMasterStepBuilder step(org.springframework.batch.core.Step step)
step in class org.springframework.batch.core.step.builder.PartitionStepBuilderpublic RemotePartitioningMasterStepBuilder splitter(org.springframework.batch.core.partition.StepExecutionSplitter splitter)
splitter in class org.springframework.batch.core.step.builder.PartitionStepBuilderpublic RemotePartitioningMasterStepBuilder aggregator(org.springframework.batch.core.partition.support.StepExecutionAggregator aggregator)
aggregator in class org.springframework.batch.core.step.builder.PartitionStepBuilderpublic RemotePartitioningMasterStepBuilder startLimit(int startLimit)
startLimit in class org.springframework.batch.core.step.builder.StepBuilderHelper<org.springframework.batch.core.step.builder.PartitionStepBuilder>public RemotePartitioningMasterStepBuilder listener(java.lang.Object listener)
listener in class org.springframework.batch.core.step.builder.StepBuilderHelper<org.springframework.batch.core.step.builder.PartitionStepBuilder>public RemotePartitioningMasterStepBuilder 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 RemotePartitioningMasterStepBuilder allowStartIfComplete(boolean allowStartIfComplete)
allowStartIfComplete in class org.springframework.batch.core.step.builder.StepBuilderHelper<org.springframework.batch.core.step.builder.PartitionStepBuilder>public RemotePartitioningMasterStepBuilder partitionHandler(org.springframework.batch.core.partition.PartitionHandler partitionHandler) throws java.lang.UnsupportedOperationException
UnsupportedOperationException since
the partition handler of the master step will be automatically set to an
instance of MessageChannelPartitionHandler.
When building a master 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