第 108 章 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>108.1. URI 格式
目前，Flink 组件只支持 Producers。一个可以创建 DataSet、DataStream 作业。
flink:dataset?dataset=#myDataSet&dataSetCallback=#dataSetCallback flink:datastream?datastream=#myDataStream&dataStreamCallback=#dataStreamCallback
FlinkEndpoint 选项
Apache Flink 端点使用 URI 语法进行配置：
flink:endpointType
使用以下路径和查询参数：
108.1.1. 路径参数(1 参数)：
| 名称 | 描述 | 默认值 | 类型 |
|---|---|---|---|
| endpointType | 端点 所需的 类型(dataset、datastream)。 | EndpointType |
108.1.2. 查询参数(6 参数)：
| 名称 | 描述 | 默认值 | 类型 |
|---|---|---|---|
| collect (producer) | 指明是否应收集或计算结果。 | true | 布尔值 |
| dataSet (producer) | 要计算的数据集。 | DataSet | |
| dataSetCallback (producer) | 对 DataSet 执行操作的功能。 | DataSetCallback | |
| dataStream (producer) | 要计算的数据流。 | DataStream | |
| dataStreamCallback (producer) | 对 DataStream 执行操作的功能。 | DataStreamCallback | |
| 同步 (advanced) | 设置是否应严格使用同步处理，或者 Camel 允许使用异步处理（如果受支持）。 | false | 布尔值 |
