第156章 Ignite Compute コンポーネント
Camel バージョン 2.17 以降で利用可能
Ignite Compute エンドポイントは camel-ignite エンドポイントの 1 つで、必要に応じてパラメーターと共に IgniteCallable、IgniteRunnable、IgniteClosure、またはそれらのコレクションを渡すことにより、クラスターで コンピュート操作 を実行できます。
このエンドポイントはプロデューサーのみをサポートします。
エンドポイント URI のホスト部分は、シンボリックエンドポイント ID であり、いかなる目的にも使用されません。
エンドポイントは、IN メッセージの本文で渡されたオブジェクトをコンピューティングジョブとして実行しようとします。実行タイプに応じて、さまざまなペイロードタイプが想定されます。
156.1. オプション
Ignite Compute コンポーネントは、以下に示す 4 個のオプションをサポートしています。
| 名前 | 説明 | デフォルト | タイプ |
|---|---|---|---|
| ignite (producer) | Ignite インスタンスを設定します。 | Ignite | |
| configurationResource (producer) | 設定をロードするリソースを設定します。URI、文字列 (URI)、または InputStream のいずれかです。 | Object | |
| igniteConfiguration (producer) | ユーザーがプログラムによる IgniteConfiguration を設定できるようにします。 | IgniteConfiguration | |
| resolveProperty Placeholders (advanced) | 起動時にコンポーネントがプロパティープレースホルダーを解決するかどうか。String タイプのプロパティーのみがプロパティープレースホルダーを使用できます。 | true | boolean |
Ignite Compute エンドポイントは、URI 構文を使用して設定されます。
ignite-compute:endpointId
パスおよびクエリーパラメーターを使用します。
156.1.1. パスパラメーター (1 個のパラメーター):
| 名前 | 説明 | デフォルト | タイプ |
|---|---|---|---|
| endpointId | 必須 エンドポイント ID (使用されません)。 | String |
156.1.2. クエリーパラメーター (8 つのパラメーター):
| 名前 | 説明 | デフォルト | タイプ |
|---|---|---|---|
| clusterGroupExpression (producer) | IgniteCompute インスタンスのクラスターグループを返す式。 | ClusterGroupExpression | |
| computeName (producer) | IgniteCompute#withName (String) で設定されるコンピュートジョブの名前。 | String | |
| executionType (producer) | 必須 実行するコンピュート操作。可能な値: CALL、BROADCAST、APPLY、EXECUTE、RUN、AFFINITY_CALL、AFFINITY_RUN。コンポーネントは、操作に応じて異なるペイロードタイプを想定しています。 | IgniteComputeExecution 型 | |
| propagateIncomingBodyIfNo ReturnValue (producer) | 基になる Ignite 操作の戻り値の型が void の場合に、入力ボディーを伝播するかどうかを設定します。 | true | boolean |
| taskName (producer) | タスク名。IgniteComputeExecutionType#EXECUTE 実行タイプを使用する場合にのみ適用されます。 | String | |
| timeoutMillis (producer) | トリガーされたジョブのタイムアウト間隔 (ミリ秒)。IgniteCompute#withTimeout (long) で設定されます。 | Long | |
| treatCollectionsAsCache Objects (producer) | コレクションをキャッシュオブジェクトとして扱うか、アイテムのコレクションとして扱うかを設定し、挿入/更新/計算などを行います。 | false | boolean |
| synchronous (advanced) | 同期処理を厳密に使用するか、Camel が非同期処理を使用できるかどうかを設定します (サポートされている場合)。 | false | boolean |
