public class RemotePartitioningWorkerStepBuilder
extends org.springframework.batch.core.step.builder.StepBuilder
IntegrationFlow that:
StepExecutionRequests coming from the master
on the input channelStepExecutionRequestHandler to execute the worker
step for each incoming request. The worker step is located using the provided
StepLocator. If no StepLocator is provided, a BeanFactoryStepLocator
configured with the current BeanFactory will be used
NullChannel will be used (assuming the master side
is configured to poll the job repository for workers status)| Constructor and Description |
|---|
RemotePartitioningWorkerStepBuilder(java.lang.String name)
Initialize a step builder for a step with the given name.
|
| Modifier and Type | Method and Description |
|---|---|
RemotePartitioningWorkerStepBuilder |
allowStartIfComplete(boolean allowStartIfComplete) |
RemotePartitioningWorkerStepBuilder |
beanFactory(org.springframework.beans.factory.BeanFactory beanFactory)
Set the bean factory.
|
<I,O> org.springframework.batch.core.step.builder.SimpleStepBuilder<I,O> |
chunk(org.springframework.batch.repeat.CompletionPolicy completionPolicy) |
<I,O> org.springframework.batch.core.step.builder.SimpleStepBuilder<I,O> |
chunk(int chunkSize) |
org.springframework.batch.core.step.builder.FlowStepBuilder |
flow(org.springframework.batch.core.job.flow.Flow flow) |
RemotePartitioningWorkerStepBuilder |
inputChannel(org.springframework.messaging.MessageChannel inputChannel)
Set the input channel on which step execution requests sent by the master
are received.
|
org.springframework.batch.core.step.builder.JobStepBuilder |
job(org.springframework.batch.core.Job job) |
RemotePartitioningWorkerStepBuilder |
jobExplorer(org.springframework.batch.core.explore.JobExplorer jobExplorer)
Set the job explorer.
|
RemotePartitioningWorkerStepBuilder |
listener(java.lang.Object listener) |
RemotePartitioningWorkerStepBuilder |
listener(org.springframework.batch.core.StepExecutionListener listener) |
RemotePartitioningWorkerStepBuilder |
outputChannel(org.springframework.messaging.MessageChannel outputChannel)
Set the output channel on which replies will be sent to the master step.
|
org.springframework.batch.core.step.builder.PartitionStepBuilder |
partitioner(org.springframework.batch.core.Step step) |
org.springframework.batch.core.step.builder.PartitionStepBuilder |
partitioner(java.lang.String stepName,
org.springframework.batch.core.partition.support.Partitioner partitioner) |
RemotePartitioningWorkerStepBuilder |
repository(org.springframework.batch.core.repository.JobRepository jobRepository) |
RemotePartitioningWorkerStepBuilder |
startLimit(int startLimit) |
RemotePartitioningWorkerStepBuilder |
stepLocator(org.springframework.batch.core.step.StepLocator stepLocator)
Set the step locator used to locate the worker step to execute.
|
org.springframework.batch.core.step.builder.TaskletStepBuilder |
tasklet(org.springframework.batch.core.step.tasklet.Tasklet tasklet) |
RemotePartitioningWorkerStepBuilder |
transactionManager(org.springframework.transaction.PlatformTransactionManager transactionManager) |
public RemotePartitioningWorkerStepBuilder(java.lang.String name)
name - the name of the steppublic RemotePartitioningWorkerStepBuilder inputChannel(org.springframework.messaging.MessageChannel inputChannel)
inputChannel - the input channelpublic RemotePartitioningWorkerStepBuilder outputChannel(org.springframework.messaging.MessageChannel outputChannel)
outputChannel - the input channelpublic RemotePartitioningWorkerStepBuilder jobExplorer(org.springframework.batch.core.explore.JobExplorer jobExplorer)
jobExplorer - the job explorer to usepublic RemotePartitioningWorkerStepBuilder stepLocator(org.springframework.batch.core.step.StepLocator stepLocator)
stepLocator - the step locator to usepublic RemotePartitioningWorkerStepBuilder beanFactory(org.springframework.beans.factory.BeanFactory beanFactory)
beanFactory - the bean factorypublic RemotePartitioningWorkerStepBuilder repository(org.springframework.batch.core.repository.JobRepository jobRepository)
repository in class org.springframework.batch.core.step.builder.StepBuilderHelper<org.springframework.batch.core.step.builder.StepBuilder>public RemotePartitioningWorkerStepBuilder transactionManager(org.springframework.transaction.PlatformTransactionManager transactionManager)
transactionManager in class org.springframework.batch.core.step.builder.StepBuilderHelper<org.springframework.batch.core.step.builder.StepBuilder>public RemotePartitioningWorkerStepBuilder startLimit(int startLimit)
startLimit in class org.springframework.batch.core.step.builder.StepBuilderHelper<org.springframework.batch.core.step.builder.StepBuilder>public RemotePartitioningWorkerStepBuilder listener(java.lang.Object listener)
listener in class org.springframework.batch.core.step.builder.StepBuilderHelper<org.springframework.batch.core.step.builder.StepBuilder>public RemotePartitioningWorkerStepBuilder listener(org.springframework.batch.core.StepExecutionListener listener)
listener in class org.springframework.batch.core.step.builder.StepBuilderHelper<org.springframework.batch.core.step.builder.StepBuilder>public RemotePartitioningWorkerStepBuilder allowStartIfComplete(boolean allowStartIfComplete)
allowStartIfComplete in class org.springframework.batch.core.step.builder.StepBuilderHelper<org.springframework.batch.core.step.builder.StepBuilder>public org.springframework.batch.core.step.builder.TaskletStepBuilder tasklet(org.springframework.batch.core.step.tasklet.Tasklet tasklet)
tasklet in class org.springframework.batch.core.step.builder.StepBuilderpublic <I,O> org.springframework.batch.core.step.builder.SimpleStepBuilder<I,O> chunk(int chunkSize)
chunk in class org.springframework.batch.core.step.builder.StepBuilderpublic <I,O> org.springframework.batch.core.step.builder.SimpleStepBuilder<I,O> chunk(org.springframework.batch.repeat.CompletionPolicy completionPolicy)
chunk in class org.springframework.batch.core.step.builder.StepBuilderpublic org.springframework.batch.core.step.builder.PartitionStepBuilder partitioner(java.lang.String stepName,
org.springframework.batch.core.partition.support.Partitioner partitioner)
partitioner in class org.springframework.batch.core.step.builder.StepBuilderpublic org.springframework.batch.core.step.builder.PartitionStepBuilder partitioner(org.springframework.batch.core.Step step)
partitioner in class org.springframework.batch.core.step.builder.StepBuilderpublic org.springframework.batch.core.step.builder.JobStepBuilder job(org.springframework.batch.core.Job job)
job in class org.springframework.batch.core.step.builder.StepBuilderpublic org.springframework.batch.core.step.builder.FlowStepBuilder flow(org.springframework.batch.core.job.flow.Flow flow)
flow in class org.springframework.batch.core.step.builder.StepBuilder