クラス AbstractJob
java.lang.ObjectSE
org.springframework.batch.core.job.AbstractJob
- 実装済みのインターフェース一覧:
Job、StepLocator、org.springframework.beans.factory.Aware、org.springframework.beans.factory.BeanNameAware、org.springframework.beans.factory.InitializingBean
public abstract class AbstractJob
extends ObjectSE
implements Job, StepLocator, org.springframework.beans.factory.BeanNameAware, org.springframework.beans.factory.InitializingBean
Job インターフェースの抽象実装。ここでは、JobRepository、JobExecutionListener、さまざまな構成パラメーターなどの一般的な依存関係を設定します。一般的なエラー処理とリスナー呼び出しアクティビティは、実装から抽象化されています。- 作成者:
- Lucas Ward, Dave Syer, Mahmoud Ben Hassine
フィールド概要
フィールドコンストラクター概要
コンストラクター方法の概要
修飾子と型メソッド説明void必須プロパティをアサートする:JobRepository。protected abstract voiddoExecute(JobExecution execution) サブクラスが処理ロジックに集中し、リスナーとリポジトリ呼び出しを無視できるようにする拡張ポイント。final voidexecute(JobExecution execution) 指定されたジョブを実行し、すべてのリスナーとリポジトリの呼び出しを処理し、実際の処理をdoExecute(JobExecution)に委譲します。protected ExitStatusgetDefaultExitStatusForFailure(ThrowableSE ex, JobExecution execution) throwable からExitStatusへのデフォルトのマッピング。クライアントがシーケンス内の次の実行のために新しいパラメーターを生成する必要がある場合は、このインクリメンターを使用できます。JobExecutionのジョブパラメーターのバリデーター。protected JobRepositoryサブクラスがジョブリポジトリにアクセスするための簡易メソッド。getName()abstract Step指定された名前のステップを取得します。abstract CollectionSE<StringSE>ステップ名を取得します。protected final StepExecutionhandleStep(Step step, JobExecution execution) 現在のJobExecutionのコンテキストで特定のステップの処理を委譲するためのサブクラスの簡易メソッド。boolean少なくとも原則として、このジョブを再開できるかどうかを示すフラグ。voidJobExecutionListenerコールバックに単一のリスナーを登録します。voidsetBeanName(StringSE name) name プロパティがまだ設定されていない場合は設定します。voidsetJobExecutionListeners(JobExecutionListener[] listeners) JobExecutionListenerを挿入するためのパブリック setter。voidsetJobParametersIncrementer(JobParametersIncrementer jobParametersIncrementer) JobParametersIncrementerのパブリック setter。voidsetJobParametersValidator(JobParametersValidator jobParametersValidator) ジョブパラメーターのバリデータ。voidsetJobRepository(JobRepository jobRepository) ジョブの存続期間中にバッチメタドメイン(ジョブ、ステップ、実行)の状態を管理するために必要なJobRepositoryのパブリック setter。voidsetMeterRegistry(io.micrometer.core.instrument.MeterRegistry meterRegistry) voidname プロパティを設定します。voidsetObservationConvention(BatchJobObservationConvention observationConvention) voidsetObservationRegistry(io.micrometer.observation.ObservationRegistry observationRegistry) voidsetRestartable(boolean restartable) ジョブが以前に失敗した場合でも、ジョブが再起動しないようにするブールフラグ。toString()
フィールドの詳細
logger
protected static final org.apache.commons.logging.Log logger
コンストラクターの詳細
AbstractJob
public AbstractJob()デフォルトコンストラクター。AbstractJob
名前をすぐに追加するための便利なコンストラクター(必須ですが、最終的なものではありません)。- パラメーター:
name- ジョブの名前
メソッドの詳細
setJobParametersValidator
ジョブパラメーターのバリデータ。デフォルトはバニラDefaultJobParametersValidatorです。- パラメーター:
jobParametersValidator- バリデーターインスタンス
afterPropertiesSet
必須プロパティをアサートする:JobRepository。- 次で指定:
- インターフェース
org.springframework.beans.factory.InitializingBeanのafterPropertiesSet - 例外:
ExceptionSE- 関連事項:
InitializingBean.afterPropertiesSet()
setBeanName
name プロパティがまだ設定されていない場合は設定します。Spring コンテナー内のコールバックの順序のため、name プロパティが存在する場合は、最初に設定されます。Bean 定義の継承には注意が必要です。親 Bean に名前がある場合、その子にも明示的な名前が必要です。そうでない場合、一意ではありません。- 次で指定:
- インターフェース
org.springframework.beans.factory.BeanNameAwareのsetBeanName - 関連事項:
BeanNameAware.setBeanName(java.lang.String)
setName
name プロパティを設定します。このオブジェクトが Spring Bean の場合、常にデフォルト値をオーバーライドします。- パラメーター:
name- ジョブに関連付ける名前。- 関連事項:
getName
getStep
指定された名前のステップを取得します。指定された名前のステップがない場合は、null を返します。- 次で指定:
- インターフェース
StepLocatorのgetStep - パラメーター:
stepName- ステップの名前- 戻り値:
- ステップ
getStepNames
ステップ名を取得します。- 次で指定:
- インターフェース
StepLocatorのgetStepNames - 戻り値:
- ステップ名
getJobParametersValidator
インターフェースからコピーされた説明:JobJobExecutionのジョブパラメーターのバリデータ。Jobのクライアントは、起動時または実行前または実行中にパラメーターを検証する必要がある場合があります。- 次で指定:
- インターフェース
JobのgetJobParametersValidator - 戻り値:
- パラメーター値をチェックするために使用できるバリデーター (決して
nullではありません)。デフォルトはDefaultJobParametersValidatorです。
setRestartable
public void setRestartable(boolean restartable) ジョブが以前に失敗した場合でも、ジョブが再起動しないようにするブールフラグ。- パラメーター:
restartable- 設定するフラグの値 (デフォルト true)
isRestartable
public boolean isRestartable()インターフェースからコピーされた説明:Job少なくとも原則として、このジョブを再開できるかどうかを示すフラグ。- 次で指定:
- インターフェース
JobのisRestartable - 戻り値:
- 失敗後にこのジョブを再開できる場合は true。デフォルトは
trueです。 - 関連事項:
setJobParametersIncrementer
JobParametersIncrementerのパブリック setter。- パラメーター:
jobParametersIncrementer- 設定するJobParametersIncrementer
getJobParametersIncrementer
インターフェースからコピーされた説明:Jobクライアントがシーケンス内の次の実行のために新しいパラメーターを生成する必要がある場合は、このインクリメンターを使用できます。このジョブに自然なシーケンスがない場合、戻り値はnullになることがあります。- 次で指定:
- インターフェース
JobのgetJobParametersIncrementer - 戻り値:
- 新しいパラメーターを作成するために使用されるインクリメンター。デフォルトは
nullです。
setJobExecutionListeners
JobExecutionListenerを挿入するためのパブリック setter。それらはすべて、ジョブの適切な時点でリスナーコールバックが与えられます。- パラメーター:
listeners- 設定するリスナー。
registerJobExecutionListener
JobExecutionListenerコールバックに単一のリスナーを登録します。- パラメーター:
listener-JobExecutionListener
setJobRepository
ジョブの存続期間中にバッチメタドメイン(ジョブ、ステップ、実行)の状態を管理するために必要なJobRepositoryのパブリック setter。- パラメーター:
jobRepository- ジョブの実行中に使用するリポジトリ
getJobRepository
サブクラスがジョブリポジトリにアクセスするための簡易メソッド。- 戻り値:
- jobRepository
doExecute
サブクラスが処理ロジックに集中し、リスナーとリポジトリ呼び出しを無視できるようにする拡張ポイント。実装は通常、ステップの順序に関係し、実際のステップ処理をhandleStep(Step, JobExecution)に委譲します。- パラメーター:
execution- 現在のJobExecution- 例外:
JobExecutionException- 致命的なバッチフレームワークエラーを通知する (ビジネスまたは検証の例外ではない)
execute
指定されたジョブを実行し、すべてのリスナーとリポジトリの呼び出しを処理し、実際の処理をdoExecute(JobExecution)に委譲します。- 次で指定:
- インターフェース
Jobのexecute - パラメーター:
execution-JobExecution- 例外:
StartLimitExceededException- いずれかのステップの開始制限を超えた場合- 関連事項:
handleStep
protected final StepExecution handleStep(Step step, JobExecution execution) throws JobInterruptedException, JobRestartException, StartLimitExceededException サブクラスが現在のJobExecutionのコンテキストで特定のステップの処理を委譲するための簡易メソッド。このメソッドのクライアントは、JobRepositoryにアクセスする必要はありません。また、再起動時に実行コンテキストに入力したり、中断された状態(ジョブまたはステップの実行中)を検出したりする必要もありません。- パラメーター:
step- 実行するStepexecution- 現在のJobExecution- 戻り値:
- このステップに対応する
StepExecution - 例外:
JobInterruptedException-JobExecutionが中断された場合、特にBatchStatus.ABANDONEDまたはBatchStatus.STOPPINGが検出された場合StartLimitExceededException- このステップの開始制限を超えている場合JobRestartException- ジョブが以前の失敗と矛盾した状態にある場合
getDefaultExitStatusForFailure
throwable からExitStatusへのデフォルトのマッピング。- パラメーター:
ex- 失敗の原因execution-JobExecutionインスタンス。- 戻り値:
ExitStatus
setObservationConvention
setObservationRegistry
public void setObservationRegistry(io.micrometer.observation.ObservationRegistry observationRegistry) setMeterRegistry
public void setMeterRegistry(io.micrometer.core.instrument.MeterRegistry meterRegistry) toString