使用 Apache Beam 创建 Kinesis Data Analytics 应用程序 - Amazon Kinesis Data Analytics
将 Apache Beams 与 Kinesis Data光束能力
Amazon Web Services 文档中描述的 Amazon Web Services 服务或功能可能因区域而异。要查看适用于中国区域的差异，请参阅 中国的 Amazon Web Services 服务入门 (PDF)。

本文属于机器翻译版本。若本译文内容与英语原文存在差异，则一律以英文原文为准。

使用 Apache Beam 创建 Kinesis Data Analytics 应用程序

您可以将 Apache Beam 框架与 Kinesis Data Analytics 应用程序一起使用来处理流数据。使用 Apache Beam 的 Kinesis Data Analytics 应用程序使用 Apache Flink runner 来执行 Beam 流水线。

有关如何在 Kinesis Data Analytics 应用程序中使用的教— 示— 示— 示— 示— 示— 示— 示— 示— 示 CloudFormation 与 Kinesis Data Analytics 使用 Apache Beam 创建应用程序 — 示

本主题包含下列部分：

将 Apache Beams 与 Kinesis Data

关于将 Apache Flink 运行器与 Kinesis Data Analytics 一起使用，请注意以下几点：

  • 无法在 Kinesis Data Analytics 控制台中查看 Apache Beam 指标。

  • 只有使用 Apache Flink 版本 1.8 及更高版本的 Kinesis Data Analytics 应用程序支持 Apache Beam。使用 Apache Flink 版本 1.6 的 Kinesis Data Analytics 应用程序不支持 Apache Beam。

光束能力

Kinesis Data Analytics 支持与 Apache Flink 运行器相同的 Apache Beam 功能。有关 Apache Flink 运行器支持哪些功能的信息，请参阅 Bea m 兼容性矩阵。

我们建议您在 Kinesis Data Analytics 服务中测试 Apache Flink 应用程序，以验证我们是否支持您的应用程序所需的所有功能。