类 PartitionStepBuilder

构造器详细资料

• PartitionStepBuilder

  public PartitionStepBuilder​(StepBuilderHelper<?> parent)

  Create a new builder initialized with any properties in the parent. The parent is copied, so it can be re-used.

  参数:

  parent - a parent helper containing common step properties

方法详细资料

• partitioner

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

  Add a partitioner which can be used to create a StepExecutionSplitter. Use either this or an explicit splitter(StepExecutionSplitter) but not both.

  参数:

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

  partitioner - a partitioner to use

  返回:

  this for fluent chaining

• step

  public PartitionStepBuilder step​(Step step)

  Provide an actual step instance to execute in parallel. If an explicit 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 - a step to execute in parallel

  返回:

  this for fluent chaining

• taskExecutor

  public PartitionStepBuilder taskExecutor​(org.springframework.core.task.TaskExecutor taskExecutor)

  Provide a task executor to use when constructing a PartitionHandler from the step(Step). Mainly used for running a step locally in parallel, but can be used to execute remotely if the step is remote. Not used if an explicit partitionHandler(PartitionHandler) is provided.

  参数:

  taskExecutor - a task executor to use when executing steps in parallel

  返回:

  this for fluent chaining

• partitionHandler

  public PartitionStepBuilder partitionHandler​(PartitionHandler partitionHandler)

  Provide an explicit partition handler that will carry out the work of the partition step. The partition handler is the main SPI for adapting a partition step to a specific distributed computation environment. Optional if you only need local or remote processing through the Step interface.

  参数:

  partitionHandler - a partition handler

  返回:

  this for fluent chaining

  另请参阅:

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

• gridSize

  public PartitionStepBuilder gridSize​(int gridSize)

  A hint to the splitter(StepExecutionSplitter) about how many step executions are required. If running locally or remotely through a taskExecutor(TaskExecutor) determines precisely the number of step executions in the first attempt at a partition step execution.

  参数:

  gridSize - the grid size

  返回:

  this for fluent chaining

• splitter

  public PartitionStepBuilder splitter​(StepExecutionSplitter splitter)

  Provide an explicit StepExecutionSplitter instead of having one build from the partitioner(String, Partitioner). Useful if you need more control over the splitting.

  参数:

  splitter - a step execution splitter

  返回:

  this for fluent chaining

• aggregator

  public PartitionStepBuilder aggregator​(StepExecutionAggregator aggregator)

  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 - a step execution aggregator

  返回:

  this for fluent chaining

• build

  public Step build()

• getTaskExecutor

  protected org.springframework.core.task.TaskExecutor getTaskExecutor()

• getPartitioner

  protected Partitioner getPartitioner()

• getStep

  protected Step getStep()

• getPartitionHandler

  protected PartitionHandler getPartitionHandler()

• getGridSize

  protected int getGridSize()

• getSplitter

  protected StepExecutionSplitter getSplitter()

• getAggregator

  protected StepExecutionAggregator getAggregator()

• getStepName

  protected java.lang.String getStepName()