第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