第107章 Apache Flink コンポーネント
Camel バージョン 2.18 以降で利用可能
このドキュメントページでは、Apache Camel の Apache Flink コンポーネントについて説明します。camel-flink コンポーネントは、Camel コネクターと Flink タスクの間のブリッジを提供します。
この Camel Flink コネクターは、さまざまなトランスポートからメッセージをルーティングし、実行する flink タスクを動的に選択し、着信メッセージをタスクの入力データとして使用し、最終的に結果を Camel パイプラインに戻す方法を提供します。
Maven ユーザーは、このコンポーネントの pom.xml に以下の依存関係を追加する必要があります。
<dependency>
<groupId>org.apache.camel</groupId>
<artifactId>camel-flink</artifactId>
<version>x.x.x</version>
<!-- use the same version as your Camel core version -->
</dependency>107.1. URI 形式
現在、Flink コンポーネントはプロデューサーのみをサポートしています。DataSet、DataStream ジョブを作成できます。
flink:dataset?dataset=#myDataSet&dataSetCallback=#dataSetCallback flink:datastream?datastream=#myDataStream&dataStreamCallback=#dataStreamCallback
FlinkEndpoint オプション
Apache Flink エンドポイントは、URI 構文を使用して設定されます。
flink:endpointType
パスおよびクエリーパラメーターを使用します。
107.1.1. パスパラメーター (1 個のパラメーター):
| 名前 | 説明 | デフォルト | タイプ |
|---|---|---|---|
| endpointType | 必須 エンドポイントのタイプ (データセット、データストリーム)。 | EndpointType |
107.1.2. クエリーパラメーター (6 個のパラメーター):
| 名前 | 説明 | デフォルト | タイプ |
|---|---|---|---|
| collect (producer) | 結果を収集またはカウントする必要があるかどうかを示します。 | true | boolean |
| dataSet (producer) | 計算対象の DataSet。 | DataSet | |
| dataSetCallback (producer) | DataSet に対してアクションを実行する関数。 | DataSetCallback | |
| dataStream (producer) | 計算対象の DataStream。 | DataStream | |
| dataStreamCallback (producer) | DataStream に対してアクションを実行する関数。 | DataStreamCallback | |
| synchronous (advanced) | 同期処理を厳密に使用するか、Camel が非同期処理を使用できるかどうかを設定します (サポートされている場合)。 | false | boolean |
