类 RemotePartitioningMasterStepBuilder

构造器详细资料

• RemotePartitioningMasterStepBuilder

  public RemotePartitioningMasterStepBuilder​(java.lang.String stepName)

  Create a new RemotePartitioningMasterStepBuilder.

  参数:

  stepName - name of the master step

方法详细资料

• inputChannel

  public RemotePartitioningMasterStepBuilder inputChannel​(org.springframework.messaging.MessageChannel inputChannel)

  Set the input channel on which replies from workers will be received.

  参数:

  inputChannel - the input channel

  返回:

  this builder instance for fluent chaining

• outputChannel

  public RemotePartitioningMasterStepBuilder outputChannel​(org.springframework.messaging.MessageChannel outputChannel)

  Set the output channel on which requests to workers will be sent. By using this setter, a default messaging template will be created and the output channel will be set as its default channel.

  Use either this setter or messagingTemplate(MessagingTemplate) to provide a fully configured messaging template.

  参数:

  outputChannel - the output channel.

  返回:

  this builder instance for fluent chaining

  另请参阅:

  messagingTemplate(MessagingTemplate)

• messagingTemplate

  public RemotePartitioningMasterStepBuilder messagingTemplate​(org.springframework.integration.core.MessagingTemplate messagingTemplate)

  Set the 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 use

  返回:

  this builder instance for fluent chaining

  另请参阅:

  outputChannel(MessageChannel)

• jobExplorer

  public RemotePartitioningMasterStepBuilder jobExplorer​(JobExplorer jobExplorer)

  Set the job explorer.

  参数:

  jobExplorer - the job explorer to use.

  返回:

  this builder instance for fluent chaining

• pollInterval

  public RemotePartitioningMasterStepBuilder pollInterval​(long pollInterval)

  How often to poll the job repository for the status of the workers. Defaults to 10 seconds.

  参数:

  pollInterval - the poll interval value in milliseconds

  返回:

  this builder instance for fluent chaining

• timeout

  public RemotePartitioningMasterStepBuilder timeout​(long timeout)

  When using job repository polling, the time limit to wait. Defaults to -1 (no timeout).

  参数:

  timeout - the timeout value in milliseconds

  返回:

  this builder instance for fluent chaining

• beanFactory

  public RemotePartitioningMasterStepBuilder beanFactory​(org.springframework.beans.factory.BeanFactory beanFactory)

  Set the bean factory.

  参数:

  beanFactory - the bean factory to use

  返回:

  this builder instance for fluent chaining

• build

  public Step build()

  覆盖:

  build 在类中 PartitionStepBuilder

• repository

  public RemotePartitioningMasterStepBuilder repository​(JobRepository jobRepository)

  覆盖:

  repository 在类中 StepBuilderHelper<PartitionStepBuilder>

• transactionManager

  public RemotePartitioningMasterStepBuilder transactionManager​(org.springframework.transaction.PlatformTransactionManager transactionManager)

  覆盖:

  transactionManager 在类中 StepBuilderHelper<PartitionStepBuilder>

• partitioner

  public RemotePartitioningMasterStepBuilder partitioner​(java.lang.String slaveStepName,
                                                         Partitioner partitioner)

  从类复制的说明: PartitionStepBuilder
  Add a partitioner which can be used to create a StepExecutionSplitter. Use either this or an explicit PartitionStepBuilder.splitter(StepExecutionSplitter) but not both.

  覆盖:

  partitioner 在类中 PartitionStepBuilder

  参数:

  slaveStepName - the name of the slave step (used to construct step execution names)

  partitioner - a partitioner to use

  返回:

  this for fluent chaining

• gridSize

  public RemotePartitioningMasterStepBuilder gridSize​(int gridSize)

  从类复制的说明: PartitionStepBuilder
  A hint to the PartitionStepBuilder.splitter(StepExecutionSplitter) about how many step executions are required. If running locally or remotely through a PartitionStepBuilder.taskExecutor(TaskExecutor) determines precisely the number of step executions in the first attempt at a partition step execution.

  覆盖:

  gridSize 在类中 PartitionStepBuilder

  参数:

  gridSize - the grid size

  返回:

  this for fluent chaining

• step

  public RemotePartitioningMasterStepBuilder step​(Step step)

  从类复制的说明: PartitionStepBuilder
  Provide an actual step instance to execute in parallel. If an explicit PartitionStepBuilder.partitionHandler(PartitionHandler) is provided, the step is optional and is only used to extract configuration data (name and other basic properties of a step).

  覆盖:

  step 在类中 PartitionStepBuilder

  参数:

  step - a step to execute in parallel

  返回:

  this for fluent chaining

• splitter

  public RemotePartitioningMasterStepBuilder splitter​(StepExecutionSplitter splitter)

  从类复制的说明: PartitionStepBuilder
  Provide an explicit StepExecutionSplitter instead of having one build from the PartitionStepBuilder.partitioner(String, Partitioner). Useful if you need more control over the splitting.

  覆盖:

  splitter 在类中 PartitionStepBuilder

  参数:

  splitter - a step execution splitter

  返回:

  this for fluent chaining

• aggregator

  public RemotePartitioningMasterStepBuilder aggregator​(StepExecutionAggregator aggregator)

  从类复制的说明: PartitionStepBuilder
  Provide a step execution aggregator for aggregating partitioned step executions into a single result for the PartitionStep itself. Default is a simple implementation that works in most cases.

  覆盖:

  aggregator 在类中 PartitionStepBuilder

  参数:

  aggregator - a step execution aggregator

  返回:

  this for fluent chaining

• startLimit

  public RemotePartitioningMasterStepBuilder startLimit​(int startLimit)

  覆盖:

  startLimit 在类中 StepBuilderHelper<PartitionStepBuilder>

• listener

  public RemotePartitioningMasterStepBuilder listener​(java.lang.Object listener)

  从类复制的说明: StepBuilderHelper
  Registers objects using the annotation based listener configuration.

  覆盖:

  listener 在类中 StepBuilderHelper<PartitionStepBuilder>

  参数:

  listener - the object that has a method configured with listener annotation

  返回:

  this for fluent chaining

• listener

  public RemotePartitioningMasterStepBuilder listener​(StepExecutionListener listener)

  覆盖:

  listener 在类中 StepBuilderHelper<PartitionStepBuilder>

• allowStartIfComplete

  public RemotePartitioningMasterStepBuilder allowStartIfComplete​(boolean allowStartIfComplete)

  覆盖:

  allowStartIfComplete 在类中 StepBuilderHelper<PartitionStepBuilder>

• partitionHandler

  public RemotePartitioningMasterStepBuilder partitionHandler​(PartitionHandler partitionHandler)
                                                       throws java.lang.UnsupportedOperationException

  This method will throw a 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 在类中 PartitionStepBuilder

  参数:

  partitionHandler - a partition handler

  返回:

  this builder instance for fluent chaining

  抛出:

  java.lang.UnsupportedOperationException - if a partition handler is provided

  另请参阅:

  for setting up a default handler that works with a local or remote Step