インターフェース TaskExecutionDao

メソッドの詳細

• createTaskExecution

  TaskExecution createTaskExecution(StringSE taskName, LocalDateTimeSE startTime, ListSE<StringSE> arguments, StringSE externalExecutionId)

  新しい TaskExecution を保存します。

  パラメーター:

  taskName - タスク実行に関連付けられた名前。

  startTime - 時間タスクが始まりました。

  arguments - タスクを構成するキー / 値のペアのリスト。

  externalExecutionId - プラットフォームによってタスクに割り当てられた ID

  戻り値:

  完全に修飾された TaskExecution インスタンス。

• createTaskExecution

  TaskExecution createTaskExecution(StringSE taskName, LocalDateTimeSE startTime, ListSE<StringSE> arguments, StringSE externalExecutionId, LongSE parentExecutionId)

  新しい TaskExecution を保存します。

  パラメーター:

  taskName - タスク実行に関連付けられた名前。

  startTime - 時間タスクが始まりました。

  arguments - タスクを構成するキー / 値のペアのリスト。

  externalExecutionId - プラットフォームによってタスクに割り当てられた ID

  parentExecutionId - 親タスク実行 ID。

  戻り値:

  完全に修飾された TaskExecution インスタンス。

  導入:

  1.2.0

• startTaskExecution

  TaskExecution startTaskExecution(long executionId, StringSE taskName, LocalDateTimeSE startTime, ListSE<StringSE> arguments, StringSE externalExecutionId)

  既存の TaskExecution を更新して、開始済みとしてマークします。

  パラメーター:

  executionId - 更新する taskExecution の ID。

  taskName - タスク実行に関連付けられた名前。

  startTime - 時間タスクが始まりました。

  arguments - タスクを構成するキー / 値のペアのリスト。

  externalExecutionId - プラットフォームによってタスクに割り当てられた ID

  戻り値:

  タスク実行開始時に利用可能な情報を含む TaskExecution。

  導入:

  1.1.0

• startTaskExecution

  TaskExecution startTaskExecution(long executionId, StringSE taskName, LocalDateTimeSE startTime, ListSE<StringSE> arguments, StringSE externalExecutionId, LongSE parentExecutionId)

  既存の TaskExecution を更新して、開始済みとしてマークします。

  パラメーター:

  executionId - 更新する taskExecution の ID。

  taskName - タスク実行に関連付けられた名前。

  startTime - 時間タスクが始まりました。

  arguments - タスクを構成するキー / 値のペアのリスト。

  externalExecutionId - プラットフォームによってタスクに割り当てられた ID

  parentExecutionId - 親タスク実行 ID。

  戻り値:

  タスク実行開始時に利用可能な情報を含む TaskExecution。

  導入:

  1.2.0

• completeTaskExecution

  void completeTaskExecution(long executionId, IntegerSE exitCode, LocalDateTimeSE endTime, StringSE exitMessage, StringSE errorMessage)

  既存の TaskExecution を更新して完了としてマークします。

  パラメーター:

  executionId - 更新する taskExecution の ID。

  exitCode - タスク完了時のステータス。

  endTime - タスクが完了した時刻。

  exitMessage - タスクの補完時に割り当てられたメッセージ。

  errorMessage - タスクが失敗したときに利用できるエラー情報。

  導入:

  1.1.0

• completeTaskExecution

  void completeTaskExecution(long executionId, IntegerSE exitCode, LocalDateTimeSE endTime, StringSE exitMessage)

  既存の TaskExecution を更新します。

  パラメーター:

  executionId - 更新する taskExecution の ID。

  exitCode - タスク完了時のステータス。

  endTime - タスクが完了した時刻。

  exitMessage - タスクの補完時に割り当てられたメッセージ。

• getTaskExecution

  TaskExecution getTaskExecution(long executionId)

  タスクリポジトリからタスク実行を取得します。

  パラメーター:

  executionId - タスク実行に関連付けられた ID。

  戻り値:

  完全に修飾された TaskExecution インスタンス。

• getTaskExecutionCountByTaskName

  long getTaskExecutionCountByTaskName(StringSE taskName)

  taskName の現在のタスク実行数を取得します。

  パラメーター:

  taskName - リポジトリ内で検索するタスクの名前。

  戻り値:

  taskName の現在のタスク実行数。

• getRunningTaskExecutionCountByTaskName

  long getRunningTaskExecutionCountByTaskName(StringSE taskName)

  taskName および endTime が null の現在のタスク実行数を取得します。

  パラメーター:

  taskName - リポジトリ内で検索するタスクの名前。

  戻り値:

  taskName の現在のタスク実行数。

• getRunningTaskExecutionCount

  long getRunningTaskExecutionCount()

  endTime が null の現在のタスク実行数を取得します。

  戻り値:

  現在のタスク実行数。

• getTaskExecutionCount

  long getTaskExecutionCount()

  現在のタスク実行数を取得します。

  戻り値:

  現在のタスク実行数。

• findRunningTaskExecutions

  org.springframework.data.domain.Page<TaskExecution> findRunningTaskExecutions(StringSE taskName, org.springframework.data.domain.Pageable pageable)

  taskName に対して実行されているタスク実行のセットを取得します。

  パラメーター:

  taskName - リポジトリ内で検索するタスクの名前。

  pageable - 検索の制約。

  戻り値:

  実行中のタスク実行のセット。

• findTaskExecutionsByName

  org.springframework.data.domain.Page<TaskExecution> findTaskExecutionsByName(StringSE taskName, org.springframework.data.domain.Pageable pageable)

  タスク名、開始場所、サイズ別にタスク実行のサブセットを取得します。

  パラメーター:

  taskName - リポジトリ内で検索するタスクの名前。

  pageable - 検索の制約。

  戻り値:

  ユーザーが指定した開始位置とカウントでバインドされたクエリからのタスク実行を含むリスト。

• getTaskNames

  ListSE<StringSE> getTaskNames()

  タスク実行の個別のタスク名の並べ替えられたリストを取得します。

  戻り値:

  タスクリポジトリからの個別のタスク名のリスト。

• findAll

  org.springframework.data.domain.Page<TaskExecution> findAll(org.springframework.data.domain.Pageable pageable)

  ページング可能な制約内のすべてのタスク実行を取得します。

  パラメーター:

  pageable - 検索の制約

  戻り値:

  検索結果を含むページ

• getNextExecutionId

  long getNextExecutionId()

  タスク実行に使用可能な次の実行 ID を取得します。

  戻り値:

  executionId を含む長い。

• getTaskExecutionIdByJobExecutionId

  LongSE getTaskExecutionIdByJobExecutionId(long jobExecutionId)

  リクエストされた Spring Batch ジョブ実行がコンテキスト内で実行された TaskExecution の ID を返します。見つからない場合は null を返します。

  パラメーター:

  jobExecutionId - JobExecution の ID

  戻り値:

  TaskExecution の ID

• getJobExecutionIdsByTaskExecutionId

  SetSE<LongSE> getJobExecutionIdsByTaskExecutionId(long taskExecutionId)

  タスク実行 ID に関連付けられたジョブ実行 ID を返します。

  パラメーター:

  taskExecutionId - TaskExecution の ID

  戻り値:

  タスク内で実行されたジョブ実行の ID の Set。

• updateExternalExecutionId

  void updateExternalExecutionId(long taskExecutionId, StringSE externalExecutionId)

  指定された実行 ID の externalExecutionId を更新します。

  パラメーター:

  taskExecutionId - 更新するタスクの実行 ID。

  externalExecutionId - 新しい externalExecutionId。

• getLatestTaskExecutionsByTaskNames

  ListSE<TaskExecution> getLatestTaskExecutionsByTaskNames(StringSE... taskNames)

  1 つ以上のタスク名に対して、最新の TaskExecution の ListSE を返します。最新は、最新の開始時刻によって定義されます。TaskExecution は終了している必要はありません (結果には保留中の TaskExecution が含まれる場合があります)。理論的には、同じ名前の TaskExecution に、まったく同じ開始時刻の TaskExecution が 1 つ以上ある可能性があります。その場合、最も高いタスク実行 ID を持つ TaskExecution が返されます。このメソッドは、計算で終了時刻を考慮しません。タスク実行 A がタスク実行 B の後に開始され、タスク実行 A の前に終了する場合、タスク実行 B が返されます。

  パラメーター:

  taskNames - 少なくとも 1 つのタスク名を指定する必要があります

  戻り値:

  TaskExecutions のリスト。空になる可能性はありますが、null にはなりません。

• getLatestTaskExecutionForTaskName

  TaskExecution getLatestTaskExecutionForTaskName(StringSE taskName)

  指定されたタスク名の最新のタスク実行を返します。最終的には getLatestTaskExecutionsByTaskNames(String...) と同じアルゴリズムが適用されますが、返される結果は 1 つだけです。

  パラメーター:

  taskName - null または空であってはならない

  戻り値:

  最新のタスク実行または null

  関連事項:

  • getLatestTaskExecutionsByTaskNames(String...)