第104章 Apache Flink コンポーネント
Camel バージョン 2.18 から利用可能
本ドキュメントページでは、Apache Camel の Apache Flink コンポーネントについて説明します。camel-flink コンポーネントは、Camel コネクターと Flink タスク間のブリッジを提供します。
この Camel 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>104.1. URI 形式
現在、Flink コンポーネントはプロデューサーのみをサポートします。DataSet、DataStream ジョブを作成できます。
flink:dataset?dataset=#myDataSet&dataSetCallback=#dataSetCallback flink:datastream?datastream=#myDataStream&dataStreamCallback=#dataStreamCallback
FlinkEndpoint オプション
Apache Flink エンドポイントは、URI 構文を使用して設定します。
flink:endpointType
以下の path パラメーターおよびクエリーパラメーターを使用します。
104.1.1. パスパラメーター（1 パラメーター）:
| Name | 説明 | デフォルト | Type |
|---|---|---|---|
| endpointType | エンド ポイントのタイプ（データセット、データストリーム） | EndpointType |
104.1.2. クエリーパラメーター（6 パラメーター）:
| Name | 説明 | デフォルト | Type |
|---|---|---|---|
| collect （プロデューサー） | 結果を収集またはカウントするかどうかを示します。 | true | boolean |
| dataSet (producer) | 計算先となるデータセット。 | DataSet | |
| dataSetCallback (producer) | DataSet に対するアクションの実行関数。 | DataSetCallback | |
| dataStream (producer) | 計算対象となるデータストリーム。 | DataStream | |
| dataStreamCallback (producer) | DataStream に対してアクションを実行する関数。 | DataStreamCallback | |
| 同期 （詳細） | 同期処理を厳密に使用するか、Camel が非同期処理を使用できるようにするかを設定します（サポートされている場合）。 | false | boolean |
