パッケージ org.springframework.cloud.task.repository.dao

クラス MapTaskExecutionDao

java.lang.ObjectSE
org.springframework.cloud.task.repository.dao.MapTaskExecutionDao
実装されたすべてのインターフェース:
TaskExecutionDao
public class MapTaskExecutionDao extends ObjectSE implements TaskExecutionDao
タスク実行情報をメモリ内マップに保存します。
作成者:
Glenn Renfro, Gunnar Hillert, David Turanski

  • コンストラクターの詳細

    • MapTaskExecutionDao

      public MapTaskExecutionDao()

  • メソッドの詳細

    • createTaskExecution

      public TaskExecution createTaskExecution(StringSE taskName, LocalDateTimeSE startTime, ListSE<StringSE> arguments, StringSE externalExecutionId)
      インターフェースからコピーされた説明: TaskExecutionDao
      新しい TaskExecution を保存します。
      次で指定:
      インターフェース TaskExecutionDao の createTaskExecution 
      パラメーター:
      taskName - タスク実行に関連付けられた名前。
      startTime - 時間タスクが始まりました。
      arguments - タスクを構成するキー / 値のペアのリスト。
      externalExecutionId - プラットフォームによってタスクに割り当てられた ID
      戻り値:
      完全に修飾された TaskExecution インスタンス。

    • createTaskExecution

      public TaskExecution createTaskExecution(StringSE taskName, LocalDateTimeSE startTime, ListSE<StringSE> arguments, StringSE externalExecutionId, LongSE parentExecutionId)
      インターフェースからコピーされた説明: TaskExecutionDao
      新しい TaskExecution を保存します。
      次で指定:
      インターフェース TaskExecutionDao の createTaskExecution 
      パラメーター:
      taskName - タスク実行に関連付けられた名前。
      startTime - 時間タスクが始まりました。
      arguments - タスクを構成するキー / 値のペアのリスト。
      externalExecutionId - プラットフォームによってタスクに割り当てられた ID
      parentExecutionId - 親タスク実行 ID。
      戻り値:
      完全に修飾された TaskExecution インスタンス。

    • startTaskExecution

      public TaskExecution startTaskExecution(long executionId, StringSE taskName, LocalDateTimeSE startTime, ListSE<StringSE> arguments, StringSE externalExecutionid)
      インターフェースからコピーされた説明: TaskExecutionDao
      既存の TaskExecution を更新して、開始済みとしてマークします。
      次で指定:
      インターフェース TaskExecutionDao の startTaskExecution 
      パラメーター:
      executionId - 更新する taskExecution の ID。
      taskName - タスク実行に関連付けられた名前。
      startTime - 時間タスクが始まりました。
      arguments - タスクを構成するキー / 値のペアのリスト。
      externalExecutionid - プラットフォームによってタスクに割り当てられた ID
      戻り値:
      タスク実行開始時に利用可能な情報を含む TaskExecution。

    • startTaskExecution

      public TaskExecution startTaskExecution(long executionId, StringSE taskName, LocalDateTimeSE startTime, ListSE<StringSE> arguments, StringSE externalExecutionid, LongSE parentExecutionId)
      インターフェースからコピーされた説明: TaskExecutionDao
      既存の TaskExecution を更新して、開始済みとしてマークします。
      次で指定:
      インターフェース TaskExecutionDao の startTaskExecution 
      パラメーター:
      executionId - 更新する taskExecution の ID。
      taskName - タスク実行に関連付けられた名前。
      startTime - 時間タスクが始まりました。
      arguments - タスクを構成するキー / 値のペアのリスト。
      externalExecutionid - プラットフォームによってタスクに割り当てられた ID
      parentExecutionId - 親タスク実行 ID。
      戻り値:
      タスク実行開始時に利用可能な情報を含む TaskExecution。

    • completeTaskExecution

      public void completeTaskExecution(long executionId, IntegerSE exitCode, LocalDateTimeSE endTime, StringSE exitMessage, StringSE errorMessage)
      インターフェースからコピーされた説明: TaskExecutionDao
      既存の TaskExecution を更新して完了としてマークします。
      次で指定:
      インターフェース TaskExecutionDao の completeTaskExecution 
      パラメーター:
      executionId - 更新する taskExecution の ID。
      exitCode - タスク完了時のステータス。
      endTime - タスクが完了した時刻。
      exitMessage - タスクの補完時に割り当てられたメッセージ。
      errorMessage - タスクが失敗したときに利用できるエラー情報。

    • completeTaskExecution

      public void completeTaskExecution(long executionId, IntegerSE exitCode, LocalDateTimeSE endTime, StringSE exitMessage)
      インターフェースからコピーされた説明: TaskExecutionDao
      既存の TaskExecution を更新します。
      次で指定:
      インターフェース TaskExecutionDao の completeTaskExecution 
      パラメーター:
      executionId - 更新する taskExecution の ID。
      exitCode - タスク完了時のステータス。
      endTime - タスクが完了した時刻。
      exitMessage - タスクの補完時に割り当てられたメッセージ。

    • getTaskExecution

      public TaskExecution getTaskExecution(long executionId)
      インターフェースからコピーされた説明: TaskExecutionDao
      タスクリポジトリからタスク実行を取得します。
      次で指定:
      インターフェース TaskExecutionDao の getTaskExecution 
      パラメーター:
      executionId - タスク実行に関連付けられた ID。
      戻り値:
      完全に修飾された TaskExecution インスタンス。

    • getTaskExecutionCountByTaskName

      public long getTaskExecutionCountByTaskName(StringSE taskName)
      インターフェースからコピーされた説明: TaskExecutionDao
      taskName の現在のタスク実行数を取得します。
      次で指定:
      インターフェース TaskExecutionDao の getTaskExecutionCountByTaskName 
      パラメーター:
      taskName - リポジトリ内で検索するタスクの名前。
      戻り値:
      taskName の現在のタスク実行数。

    • getRunningTaskExecutionCountByTaskName

      public long getRunningTaskExecutionCountByTaskName(StringSE taskName)
      インターフェースからコピーされた説明: TaskExecutionDao
      taskName および endTime が null の現在のタスク実行数を取得します。
      次で指定:
      インターフェース TaskExecutionDao の getRunningTaskExecutionCountByTaskName 
      パラメーター:
      taskName - リポジトリ内で検索するタスクの名前。
      戻り値:
      taskName の現在のタスク実行数。

    • getRunningTaskExecutionCount

      public long getRunningTaskExecutionCount()
      インターフェースからコピーされた説明: TaskExecutionDao
      endTime が null の現在のタスク実行数を取得します。
      次で指定:
      インターフェース TaskExecutionDao の getRunningTaskExecutionCount 
      戻り値:
      現在のタスク実行数。

    • getTaskExecutionCount

      public long getTaskExecutionCount()
      インターフェースからコピーされた説明: TaskExecutionDao
      現在のタスク実行数を取得します。
      次で指定:
      インターフェース TaskExecutionDao の getTaskExecutionCount 
      戻り値:
      現在のタスク実行数。

    • findRunningTaskExecutions

      public org.springframework.data.domain.Page<TaskExecution> findRunningTaskExecutions(StringSE taskName, org.springframework.data.domain.Pageable pageable)
      インターフェースからコピーされた説明: TaskExecutionDao
      taskName に対して実行されているタスク実行のセットを取得します。
      次で指定:
      インターフェース TaskExecutionDao の findRunningTaskExecutions 
      パラメーター:
      taskName - リポジトリ内で検索するタスクの名前。
      pageable - 検索の制約。
      戻り値:
      実行中のタスク実行のセット。

    • findTaskExecutionsByName

      public org.springframework.data.domain.Page<TaskExecution> findTaskExecutionsByName(StringSE taskName, org.springframework.data.domain.Pageable pageable)
      インターフェースからコピーされた説明: TaskExecutionDao
      タスク名、開始場所、サイズ別にタスク実行のサブセットを取得します。
      次で指定:
      インターフェース TaskExecutionDao の findTaskExecutionsByName 
      パラメーター:
      taskName - リポジトリ内で検索するタスクの名前。
      pageable - 検索の制約。
      戻り値:
      ユーザーが指定した開始位置とカウントでバインドされたクエリからのタスク実行を含むリスト。

    • getTaskNames

      public ListSE<StringSE> getTaskNames()
      インターフェースからコピーされた説明: TaskExecutionDao
      タスク実行の個別のタスク名の並べ替えられたリストを取得します。
      次で指定:
      インターフェース TaskExecutionDao の getTaskNames 
      戻り値:
      タスクリポジトリからの個別のタスク名のリスト。

    • findAll

      public org.springframework.data.domain.Page<TaskExecution> findAll(org.springframework.data.domain.Pageable pageable)
      インターフェースからコピーされた説明: TaskExecutionDao
      ページング可能な制約内のすべてのタスク実行を取得します。
      次で指定:
      インターフェース TaskExecutionDao の findAll 
      パラメーター:
      pageable - 検索の制約
      戻り値:
      検索結果を含むページ

    • getTaskExecutions

      public MapSE<LongSE,TaskExecution> getTaskExecutions()

    • getNextExecutionId

      public long getNextExecutionId()
      インターフェースからコピーされた説明: TaskExecutionDao
      タスク実行に使用可能な次の実行 ID を取得します。
      次で指定:
      インターフェース TaskExecutionDao の getNextExecutionId 
      戻り値:
      executionId を含む長い。

    • getTaskExecutionIdByJobExecutionId

      public LongSE getTaskExecutionIdByJobExecutionId(long jobExecutionId)
      インターフェースからコピーされた説明: TaskExecutionDao
      リクエストされた Spring Batch ジョブ実行がコンテキスト内で実行された TaskExecution の ID を返します。見つからない場合は null を返します。
      次で指定:
      インターフェース TaskExecutionDao の getTaskExecutionIdByJobExecutionId 
      パラメーター:
      jobExecutionId - JobExecution の ID
      戻り値:
      TaskExecution の ID

    • getJobExecutionIdsByTaskExecutionId

      public SetSE<LongSE> getJobExecutionIdsByTaskExecutionId(long taskExecutionId)
      インターフェースからコピーされた説明: TaskExecutionDao
      タスク実行 ID に関連付けられたジョブ実行 ID を返します。
      次で指定:
      インターフェース TaskExecutionDao の getJobExecutionIdsByTaskExecutionId 
      パラメーター:
      taskExecutionId - TaskExecution の ID
      戻り値:
      タスク内で実行されたジョブ実行の ID の Set。

    • updateExternalExecutionId

      public void updateExternalExecutionId(long taskExecutionId, StringSE externalExecutionId)
      インターフェースからコピーされた説明: TaskExecutionDao
      指定された実行 ID の externalExecutionId を更新します。
      次で指定:
      インターフェース TaskExecutionDao の updateExternalExecutionId 
      パラメーター:
      taskExecutionId - 更新するタスクの実行 ID。
      externalExecutionId - 新しい externalExecutionId。

    • getBatchJobAssociations

      public ConcurrentMapSE<LongSE,SetSE<LongSE>> getBatchJobAssociations()

    • getLatestTaskExecutionsByTaskNames

      public ListSE<TaskExecution> getLatestTaskExecutionsByTaskNames(StringSE... taskNames)
      インターフェースからコピーされた説明: TaskExecutionDao
      1 つ以上のタスク名に対して、最新の TaskExecution の ListSE を返します。最新は、最新の開始時刻によって定義されます。TaskExecution は終了している必要はありません (結果には保留中の TaskExecution が含まれる場合があります)。理論的には、同じ名前の TaskExecution に、まったく同じ開始時刻の TaskExecution が 1 つ以上ある可能性があります。その場合、最も高いタスク実行 ID を持つ TaskExecution が返されます。このメソッドは、計算で終了時刻を考慮しません。タスク実行 A がタスク実行 B の後に開始され、タスク実行 A の前に終了する場合、タスク実行 B が返されます。
      次で指定:
      インターフェース TaskExecutionDao の getLatestTaskExecutionsByTaskNames 
      パラメーター:
      taskNames - 少なくとも 1 つのタスク名を指定する必要があります
      戻り値:
      TaskExecutions のリスト。空になる可能性はありますが、null にはなりません。

    • getLatestTaskExecutionForTaskName

      public TaskExecution getLatestTaskExecutionForTaskName(StringSE taskName)
      インターフェースからコピーされた説明: TaskExecutionDao
      指定されたタスク名の最新のタスク実行を返します。最終的には TaskExecutionDao.getLatestTaskExecutionsByTaskNames(String...) と同じアルゴリズムが適用されますが、返される結果は 1 つだけです。
      次で指定:
      インターフェース TaskExecutionDao の getLatestTaskExecutionForTaskName 
      パラメーター:
      taskName - null または空であってはならない
      戻り値:
      最新のタスク実行または null
      関連事項: