接口 FlowExecutor

方法详细资料

• executeStep

  java.lang.String executeStep​(Step step)
                        throws JobInterruptedException,
                               JobRestartException,
                               StartLimitExceededException

  参数:

  step - a Step to execute

  返回:

  the exit status that drives the surrounding Flow

  抛出:

  StartLimitExceededException - thrown if start limit is exceeded.

  JobRestartException - thrown if job restart is not allowed.

  JobInterruptedException - thrown if job was interrupted.

• getJobExecution

  JobExecution getJobExecution()

  返回:

  the current JobExecution

• getStepExecution

  @Nullable
  StepExecution getStepExecution()

  返回:

  the latest StepExecution or null if there is none

• close

  void close​(FlowExecution result)

  Chance to clean up resources at the end of a flow (whether it completed successfully or not).

  参数:

  result - the final FlowExecution

• abandonStepExecution

  void abandonStepExecution()

  Handle any status changes that might be needed at the start of a state.

• updateJobExecutionStatus

  void updateJobExecutionStatus​(FlowExecutionStatus status)

  Handle any status changes that might be needed in the JobExecution.

  参数:

  status - status to update the JobExecution to.

• isRestart

  boolean isRestart()

  返回:

  true if the flow is at the beginning of a restart

• addExitStatus

  void addExitStatus​(java.lang.String code)

  参数:

  code - the label for the exit status when a flow or sub-flow ends