インターフェース JobOperator
- すべての既知の実装クラス:
SimpleJobOperator
public interface JobOperator
プリミティブ型とコレクション型にのみアクセスできるジョブをインスペクションおよび制御するための低レベルのインターフェース。コマンドラインクライアント(たとえば、操作ごとに新しいプロセスを起動する)、JMX コンソールのようなリモートランチャーに適しています。
- 導入:
- 2.0
- 作成者:
- Dave Syer, Mahmoud Ben Hassine
方法の概要
修飾子と型メソッド説明abandon(long jobExecutionId) JobExecutionを ABANDONED としてマークします。getExecutions(long instanceId) 特定のJobInstanceに関連付けられたJobExecutionsを、作成順(したがって、通常は実行順)でリストします。default JobInstancegetJobInstance(StringSE jobName, JobParameters jobParameters) getJobInstances(StringSE jobName, int start, int count) 指定されたジョブ名のJobInstancesを、作成とは逆の順序で(したがって、通常は最初に実行されたときに)リストします。start(String, Properties)で起動できる使用可能なジョブ名をリストします。getParameters(long executionId) 人間が読める文字列としてJobParametersを取得します (改行で区切られたキー = 値のペア)。getRunningExecutions(StringSE jobName) 指定されたジョブ名で実行中のすべてのJobExecutionsの ID 値を取得します。getStepExecutionSummaries(long executionId) JobExecutionに属するStepExecutionインスタンスを、指定された ID で要約し、ステータス、開始時刻、終了時刻などの詳細を示します。getSummary(long executionId) 提供された ID でJobExecutionを要約し、ステータス、開始時間と終了時間などの詳細を示します。restart(long executionId) 失敗または停止したJobExecutionを再起動します。default LongSEstart(StringSE jobName, PropertiesSE parameters) 指定されたパラメーターを使用して、ジョブの新しいインスタンスを開始します。startNextInstance(StringSE jobName) 指定されたジョブに接続されたJobParametersIncrementerによって決定されるJobInstanceのシーケンスで次を起動します。booleanstop(long executionId) 指定された ID を使用してJobExecutionに停止シグナルを送信します。
メソッドの詳細
getExecutions
特定のJobInstanceに関連付けられたJobExecutionsを、作成順(したがって、通常は実行順)でリストします。- パラメーター:
instanceId-JobInstanceの ID- 戻り値:
- このインスタンスに関連付けられているすべての
JobExecutionsの ID 値 - 例外:
NoSuchJobInstanceException-instanceIdに関連付けられたJobInstanceが見つからない場合。
getJobInstances
指定されたジョブ名のJobInstancesを、作成とは逆の順序で(したがって、通常は最初に実行されたときに)リストします。- パラメーター:
jobName- すべてのインスタンスが持つジョブ名start- インスタンスの開始インデックスcount- 返す値の最大数- 戻り値:
JobInstancesの ID 値- 例外:
NoSuchJobException- jobName のJobInstanceが存在しない場合にスローされます。
getJobInstance
- パラメーター:
jobName-StringSE ジョブの名前。jobParameters- ジョブインスタンスのJobParametersパラメーター。- 戻り値:
- 指定された名前とパラメーターを持つ
JobInstance、またはnull。 - 導入:
- 5.0
getRunningExecutions
指定されたジョブ名で実行中のすべてのJobExecutionsの ID 値を取得します。- パラメーター:
jobName- 検索するジョブの名前- 戻り値:
- 実行中の
JobExecutionインスタンスの ID 値 - 例外:
NoSuchJobException- そのジョブ名を持つJobExecutionsがない場合
getParameters
人間が読める文字列としてJobParametersを取得します (改行で区切られたキー = 値のペア)。- パラメーター:
executionId- 既存のJobExecutionの ID- 戻り値:
- 関連するインスタンスを起動するために使用されたジョブパラメーター
- 例外:
NoSuchJobExecutionException- ID がJobExecutionに関連付けられていなかった場合
start
default LongSE start(StringSE jobName, PropertiesSE parameters) throws NoSuchJobException, JobInstanceAlreadyExistsException, JobParametersInvalidException 指定されたパラメーターを使用して、ジョブの新しいインスタンスを開始します。- パラメーター:
jobName- 起動するJobの名前parameters- 起動するためのパラメーター- 戻り値:
- 起動された
JobExecutionの ID - 例外:
NoSuchJobException- 指定された名前のJobがない場合JobInstanceAlreadyExistsException- この名前とパラメーターのジョブインスタンスがすでに存在する場合JobParametersInvalidException- ジョブパラメーターのいずれかが無効な場合にスローされます。
restart
LongSE restart(long executionId) throws JobInstanceAlreadyCompleteException, NoSuchJobExecutionException, NoSuchJobException, JobRestartException, JobParametersInvalidException 失敗または停止したJobExecutionを再起動します。指定された ID が存在しないか、通常の状況ですでに正常に完了したJobInstanceに対応する場合、例外で失敗します。- パラメーター:
executionId- 失敗または停止したJobExecutionの ID- 戻り値:
- 開始された
JobExecutionの ID - 例外:
JobInstanceAlreadyCompleteException- ジョブがすでに正常に完了した場合NoSuchJobExecutionException- ID がJobExecutionに関連付けられていなかった場合NoSuchJobException-JobExecutionは見つかったが、対応するJobが起動に使用できなくなった場合JobRestartException- 再起動時に特定できないエラーが発生した場合 (たとえば破損または一貫性のない再起動データ)JobParametersInvalidException- パラメーターがこのジョブに有効でない場合
startNextInstance
LongSE startNextInstance(StringSE jobName) throws NoSuchJobException, JobParametersNotFoundException, JobRestartException, JobExecutionAlreadyRunningException, JobInstanceAlreadyCompleteException, UnexpectedJobExecutionException, JobParametersInvalidException 指定されたジョブに接続されたJobParametersIncrementerによって決定されるJobInstanceのシーケンスで次を起動します。前のインスタンスがまだ障害状態にある場合、このメソッドは新しいインスタンスを作成し、(JobParametersIncrementerが機能している限り)異なるパラメーターで実行する必要があります。
以下で説明する最後の 3 つの例外は非常に起こりそうにありませんが、完全に除外することはできません。同時にこのメソッド(または類似のメソッド)を使用しようとしている他のスレッドまたはプロセスを指します。- パラメーター:
jobName- 起動するジョブの名前- 戻り値:
- ジョブの起動時に作成された実行の
JobExecutionID - 例外:
NoSuchJobException- 利用可能なそのようなジョブ定義がない場合JobParametersNotFoundException- パラメーターが見つからない場合JobParametersInvalidException- ジョブパラメーターの一部が無効な場合にスローされます。UnexpectedJobExecutionException- 予期しない状況が発生した場合JobRestartException- ジョブが不正に再起動された場合にスローされます。JobExecutionAlreadyRunningException- すでに実行中のジョブを再開しようとするとスローされます。JobInstanceAlreadyCompleteException- 完了したジョブを再開しようとするとスローされます。
stop
指定された ID を使用してJobExecutionに停止シグナルを送信します。このメソッドが true を返した場合、シグナルは正常に送信されますが、ジョブが停止したことを意味するわけではありません。それを確認する唯一の方法は、ジョブの実行ステータスをポーリングすることです。- パラメーター:
executionId- 実行中のJobExecutionの ID- 戻り値:
- メッセージが正常に送信された場合は true (ジョブが停止したことを保証しません)
- 例外:
NoSuchJobExecutionException- 指定された ID を持つJobExecutionがない場合JobExecutionNotRunningException-JobExecutionが実行されていない場合 (止められない)
getSummary
提供された ID でJobExecutionを要約し、ステータス、開始時間と終了時間などの詳細を示します。- パラメーター:
executionId- 既存のJobExecutionの ID- 戻り値:
- ジョブ実行の状態を要約した文字列
- 例外:
NoSuchJobExecutionException- 指定された ID のJobExecutionがない場合
getStepExecutionSummaries
MapSE<LongSE,StringSE> getStepExecutionSummaries(long executionId) throws NoSuchJobExecutionException JobExecutionに属するStepExecutionインスタンスを、指定された ID で要約し、ステータス、開始時刻、終了時刻などの詳細を示します。- パラメーター:
executionId- 既存のJobExecutionの ID- 戻り値:
- ステップ実行 ID と文字列へのマップで、実行の状態を要約したもの
- 例外:
NoSuchJobExecutionException- 指定された ID のJobExecutionがない場合
getJobNames
start(String, Properties)で起動できる使用可能なジョブ名をリストします。- 戻り値:
- ジョブ名のセット
abandon
JobExecution abandon(long jobExecutionId) throws NoSuchJobExecutionException, JobExecutionAlreadyRunningException JobExecutionを ABANDONED としてマークします。プロセスが停止したために停止シグナルが無視された場合、これは(STOPPED とは対照的に)ジョブを終了済みとしてマークする最良の方法です。破棄されたジョブの実行は、フレームワークによって再開できません。- パラメーター:
jobExecutionId- 中止するジョブ実行 ID- 戻り値:
- 中止された
JobExecution - 例外:
NoSuchJobExecutionException- jobExecutionId のジョブ実行がない場合にスローされます。JobExecutionAlreadyRunningException- ジョブが実行中の場合 (最初に停止する必要があります)