すべてのクラスとインターフェース
クラス
説明
提供されるすべての SQL ページングクエリプロバイダーの基本クラスとして機能する抽象 SQL ページングクエリプロバイダー。
AmqpItemReader の自動構成。AmqpItemReader を構成するためのプロパティ。AmqpItemWriter の自動構成。 次のチャネルでイベントを発行するように設計された Spring Batch リスナーを自動構成します。
ジョブ実行リスナーの構成。
バッチジョブプラグインで使用されるヘッダー定義。
各パーティションの実行に渡されるコマンドライン引数のカスタマイズを可能にする戦略。
DB2 や oracle などのデータベース型を表す列挙型。
データベース固有の機能を使用した
PagingQueryProvider の IBMDB2 実装。TaskConfigurer インターフェースのデフォルトの実装。
/** Default
TaskExecutionObservationConvention implementation. Spring Cloud Task 用の
ObservationConvention。 各 ワーカーを
TaskLauncher に委譲する PartitionHandler 実装。Step を実行するために使用される CommandLineRunner。 埋め込みデータベースを使用する 2 つのデータソースを作成します。
TaskLifecycleListener を有効にして、Spring Cloud Task の機能を適用します。 この Boot アプリをシンクとして有効にし、
TaskLaunchRequest を受信して TaskLauncher を使用してタスクを起動します。 パーティション化されたジョブ内の各 ワーカーの環境変数の高度な構成を可能にする戦略インターフェース。
バッチジョブの
Chunk に関する情報メッセージを提供します。 バッチジョブの
ItemProcessListener に関する情報メッセージを提供します。 バッチジョブの
ItemReader に関する情報メッセージを提供します。ItemWriteEventsListener を設定して、Spring Cloud ストリーム出力チャネルにイベントを送信します。
ジョブ実行の開始時と終了時の両方で
JobExecutionEvent を提供します。SkipProcessListener を設定して、Spring Cloud ストリーム出力チャネルにイベントを送信します。
各ステップの開始時と終了時に、ステップのステータスを示す
StepExecutionEvent を提供します。ExitStatus を Json に直列化できるように ExitStatus DTO が作成されました。 外部データベースを使用する 2 つのデータソースを作成します。
FlatFileItemReader の自動構成。FieldSet を受け取り、その内容の Map<String, Object> を返す FieldSetMapper。FlatFileItemReader を構成するためのプロパティ。FlatFileItemWriter の自動構成。Map<String, Object> を、出力レコードを入力するために必要な順序付けられた Object[] に変換する FieldExtractor。FlatFileItemWriter を構成するためのプロパティ。 データベース固有の機能を使用した
PagingQueryProvider の H2 実装。 データベース固有の機能を使用した
PagingQueryProvider の HSQLDB 実装。JdbcBatchItemWriter の自動構成。JdbcBatchItemWriter を構成するためのプロパティ。TaskBatchDao の JDBC ベースの実装。 タスク実行情報を JDBC DataSource に保存します。
これは、ObjectMapper にミックスインを追加せずに
JobExecution を Json に直列化できるように作成された JobEvent DTO です。 これは、ObjectMapper にミックスインを追加せずに
JobInstance を Json に直列化できるように作成された JobInstance DTO です。TaskJobLauncher を作成するために正しい条件が満たされているかどうかを評価します。
これは、ObjectMapper にミックスインを追加せずに
JobParameter を Json に直列化できるように作成された JobParameter DTO です。 これは、ObjectMapper にミックスインを追加せずに
JobParameters を Json に直列化できるように作成された JobParametersEvent DTO です。KafkaItemReader の場合は AutoConfiguration。KafkaItemReader を構成するためのプロパティ。KafkaItemReader の自動構成。KafkaItemWriter を構成するためのプロパティ。TaskBatchDao のマップ実装。 タスク実行情報をメモリ内マップに保存します。
データベース固有の機能を使用した
PagingQueryProvider の MariaDB 実装。 バッチジョブリスナーペイロードを通知チャネルに送信するユーティリティクラス。
データベース固有の機能を使用した
PagingQueryProvider の MySQL 実装。EnvironmentVariablesProvider の単純な no-op 実装。 Spring Cloud Task の計装を登録する
Auto-configuration。 データベース固有の機能を使用した
PagingQueryProvider の Oracle 実装。 ページングクエリを生成するために提供される機能を定義するインターフェース。
提供された
List<String> を返します。 データベース固有の機能を使用した
PagingQueryProvider の Postgres 実装。start-end または start 形式のプロパティ (start と end は両方とも整数) を取得し、FlatFileItemReader を構成するための Range インスタンスに変換するコンバーター。 提供された
TaskExecution で使用されるすべてのコマンドライン引数を、構成された追加の引数とともに返します。includeCurrentEnvironment が true (デフォルト) に設定されている場合にのみ、
Environment で使用可能な既存の環境変数をすべてコピーします。Spring タスクを有効にして使用するための共通構造を提供する基本
Configuration クラス。 タスクリポジトリからタスク情報を収集する TaskExplorer です。
TaskNameResolver インターフェースの単純な実装。 タスク実行情報をログと提供された TaskExecutionDao に記録します。
spring.cloud.task.single-instance-enabled が true に設定されている場合、このリスナーは spring.cloud.task.name に基づいてタスクのロックを作成します。
単一ステップの Spring Batch ジョブを作成するための自動構成。
単一のステップジョブのステップおよびジョブレベルのプロパティを構成するプロパティ。
SingleInstanceTaskListener の自動構成。PagingQueryProvider インターフェース用のファクトリ Bean。 クエリプロバイダーが使用する実際の SQL ステートメントを生成するユーティリティクラス。
データベース固有の機能を使用した
PagingQueryProvider の SQLServer 実装。 これは、ObjectMapper にミックスインを追加せずに
StepExecution を Json に直列化できるように作成された StepExecution DTO です。Spring Boot タスクが有効になっているアプリケーション。
タイムスタンプを出力するコマンドラインランナー。
TaskBatchExecutionListener の自動構成を提供します。TaskBatchExecutionListener の自動構成。TaskExecution とその中で実行される JobExecution 間の関連付けを維持します。 リスナーをジョブとそのステップに接続します。
Spring Batch ジョブとそれが実行された Spring Cloud タスク間の関連を保存するロールを担います。
タスクのスコープ内で実行されるすべてのバッチジョブ (
AbstractJob に割り当て可能な Bean) に構成された TaskBatchExecutionListener を挿入します。TaskBatchExecutionListener の場合は FactoryBean。Spring Batch でのタスクの動作方法に使用するプロパティを確立します。
タスクシステムに構成のカスタマイズを提供するための戦略インターフェースを提供します。
あらゆるタスクの課題に対する基本例外。
各実行におけるタスクの状態を表します。
タスク実行のためのデータアクセスオブジェクト。
提供された情報に基づいて適切な
TaskExecutionDao を作成する FactoryBean 実装。 タスクの実行時にスローされます。
タスク実行イベントを受信するためのリスナーインターフェース。
使用すべきではありません。
タスク実行の観察の列挙。
ObservationHandler に必要な TaskExecution の変更可能なホルダー。TaskExecutionObservationContext の ObservationConvention。 ユーザーが利用可能なタスク実行を照会できるようにするメソッドを提供します。
ApplicationRunner から launch の Spring Batch ジョブ。TaskJobLauncherApplicationRunner のインスタンスを作成するためのファクトリ Bean。TaskJobLauncherApplicationRunner の自動構成を提供します。 パーティションの起動をサポートします。
タスクを起動するシンクストリームアプリケーション。
タスクを起動するために TaskLauncherSink に必要な maven リポジトリとプロパティ情報を含むリクエスト。
タスクのライフサイクルを監視します。
TaskExecutionListener アノテーションを含むすべての Bean を識別し、適切なタイミングで
TaskExecutionListener によって呼び出せるよう、関連付けられたメソッドを保存します。 タスク用に TaskListenerExecutor を初期化します。
タスクの名前を決定する方法をカスタマイズするための戦略インターフェース。
クラウドプロファイルがアクティブな場合、タスク
Observation の KeyValues の値を提供します。 Spring Cloud Task 用の
Observation.Context。 Spring Cloud Task 用の
ObservationConvention。Micrometer 経由で Spring Cloud Task 固有の観測を公開するためのユーティリティクラス。
タスクの maven リポジトリ座標とデータソース構成を取得し、タスクシンクに
TaskLaunchRequest メッセージを送信するプロセッサー。 タスクを構成するために使用できるプロパティ。
TaskRepository インターフェースは、タスク実行情報を作成および更新するメソッドを提供します。
タスクリポジトリのデータソースを初期化するためのユーティリティ。
BeforeTask イベントの TASK_RUN_OUTPUT テーブルにエントリを記録します。
データストアに書き込まれる ID と出力のエンティティ。
Spring Cloud Task のネイティブヒント。
タスクを起動するためのタスクシンクサンプルアプリケーション。
TaskExecutionListenerのデフォルト実装が優先される