public class JobFlowExecutor extends java.lang.Object implements FlowExecutor
JobExecution
に関連するフローを実行する必要があるコンポーネントで使用するための FlowExecutor
の実装。修飾子と型 | フィールドと説明 |
---|---|
protected ExitStatus | exitStatus |
コンストラクターと説明 |
---|
JobFlowExecutor(JobRepository jobRepository, StepHandler stepHandler, JobExecution execution) |
修飾子と型 | メソッドと説明 |
---|---|
void | abandonStepExecution() 状態の開始時に必要になる可能性のあるステータス変更を処理します。 |
void | addExitStatus(java.lang.String code) |
void | close(FlowExecution result) フローの最後に(リソースが正常に完了したかどうかにかかわらず)リソースをクリーンアップする機会。 |
java.lang.String | executeStep(Step step) |
protected BatchStatus | findBatchStatus(FlowExecutionStatus status) |
JobExecution | getJobExecution() |
StepExecution | getStepExecution() |
boolean | isRestart() |
void | updateJobExecutionStatus(FlowExecutionStatus status) JobExecution で必要になる可能性のあるステータス変更を処理します。 |
protected ExitStatus exitStatus
public JobFlowExecutor(JobRepository jobRepository, StepHandler stepHandler, JobExecution execution)
jobRepository
- JobRepository
のインスタンス。stepHandler
- StepHandler
のインスタンス。execution
- JobExecution
のインスタンス。public java.lang.String executeStep(Step step) throws JobInterruptedException, JobRestartException, StartLimitExceededException
FlowExecutor
の executeStep
step
- 実行する Step
Flow
を駆動する終了ステータス JobInterruptedException
- ジョブが中断された場合にスローされます。JobRestartException
- ジョブの再起動が許可されていない場合にスローされます。StartLimitExceededException
- 開始制限を超えた場合にスローされます。public void abandonStepExecution()
FlowExecutor
FlowExecutor
の abandonStepExecution
public void updateJobExecutionStatus(FlowExecutionStatus status)
FlowExecutor
JobExecution
で必要になる可能性のあるステータス変更を処理します。FlowExecutor
の updateJobExecutionStatus
status
- JobExecution
を更新するステータス。public JobExecution getJobExecution()
FlowExecutor
の getJobExecution
JobExecution
@Nullable public StepExecution getStepExecution()
FlowExecutor
の getStepExecution
StepExecution
。ない場合は nullpublic void close(FlowExecution result)
FlowExecutor
FlowExecutor
の close
result
- 最後の FlowExecution
public boolean isRestart()
FlowExecutor
の isRestart
public void addExitStatus(java.lang.String code)
FlowExecutor
の addExitStatus
code
- フローまたはサブフローが終了したときの終了ステータスのラベル protected BatchStatus findBatchStatus(FlowExecutionStatus status)
status
- 変換する FlowExecutionStatus
。FlowExecutionStatus
に適した BatchStatus