第 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 组件只支持 Producers。一个可以创建 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 | 端点 所需的 类型(dataset、dataset、datastream)。 | EndpointType |
107.1.2. 查询参数(6 参数)：
| 名称 | 描述 | 默认 | 类型 |
|---|---|---|---|
| collect (producer) | 指明是否应该收集或计算结果。 | true | 布尔值 |
| dataSet (producer) | 到计算的数据集， | DataSet | |
| dataSetCallback (producer) | 对 DataSet 执行操作。 | DataSetCallback | |
| dataStream (producer) | 计算的数据流. | DataStream | |
| dataStreamCallback (producer) | 对 DataStream 执行操作的功能。 | DataStreamCallback | |
| 同步 （高级） | 设置同步处理是否应当严格使用，还是允许 Camel 使用异步处理（如果受支持）。 | false | 布尔值 |
