第148章 ignite Compute コンポーネント

endpointId

必要な エンドポイント ID（不使用）。

文字列

clusterGroupExpression (producer)

IgniteCompute インスタンスのクラスターグループを返す式。

ClusterGroupExpression

computeName (producer)

リンク IgniteComputewithName(String)で設定されるコンピュートジョブの名前。

文字列

executionType (producer)

実行するコンピュート操作が 必要です。使用できる値は、CALL、BROADCAST、APPLY、EXECUTE、RUN、AFFINITY_CALL、AFFINITY_RUN です。コンポーネントは、操作に応じて異なるペイロードタイプを想定します。

IgniteComputeExecution Type

propagateIncomingBodyIfNo ReturnValue (producer)

基礎となる Ignite 操作の戻り値タイプが void の場合には、受信ボディーを伝播するかどうかを設定します。

true

boolean

taskName (producer)

タスク名。リンク IgniteComputeExecutionTypeEXECUTE 実行タイプを使用している場合にのみ該当します。

文字列

timeoutMillis (producer)

トリガーされたジョブのタイムアウト間隔（ミリ秒単位）。リンク IgniteComputewithTimeout(long)で設定されます。

Long

treatCollectionsAsCache Objects (producer)

コレクションをキャッシュオブジェクトとして処理するか、または挿入/更新/コンピュートなどを行う項目のコレクションとして処理するかどうかを設定します。

false

boolean

同期 （詳細）

同期処理を厳密に使用するか、Camel が非同期処理を使用できるようにするかを設定します（サポートされている場合）。

false

boolean

CamelIgniteComputeExecutionType

IgniteConstants.IGNITE_COMPUTE_EXECUTION_TYPE

IgniteComputeExecutionType enum

実行するコンピュート操作を動的に変更できます。

CamelIgniteComputeParameters

IgniteConstants.IGNITE_COMPUTE_PARAMS

オブジェクトのオブジェクトまたはコレクション。

APPLY、BROADCAST、および EXECUTE 操作のパラメーター。

CamelIgniteComputeReducer

IgniteConstants.IGNITE_COMPUTE_REDUCER

IgniteReducer

APPLY および CALL 操作を減らします。

CamelIgniteComputeAffinityCacheName

IgniteConstants.IGNITE_COMPUTE_AFFINITY_CACHE_NAME

文字列

AFFINITY_CALL および AFFINITY_RUN 操作のアフィニティーキャッシュ名。

CamelIgniteComputeAffinityKey

IgniteConstants.IGNITE_COMPUTE_AFFINITY_KEY

オブジェクト

AFFINITY_CALL および AFFINITY_RUN 操作のアフィニティーキー。