本文属于机器翻译版本。若本译文内容与英语原文存在差异,则一律以英文原文为准。
使用 Apache Beam 创建 Kinesis Data Analytics 应用程序
您可以使用Apache Beam
有关如何在 Kinesis Data Analytics 应用程序中使用 Apache Beam 的教程,请参阅使用CloudFormation使用 Kinesis Data Analytics Apache Beam.
将 Apache Beam 与 Kinesis Data Analytics
请注意以下关于将 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。
Beam 功能
Kinesis Data Analytics 支持与 Apache Flink 跑步者相同的 Apache Beam 功能。有关 Apache Flink 运行器支持哪些功能的信息,请参阅Beam 兼容性矩阵
我们建议您在 Kinesis Data Analytics 服务中测试 Apache Flink 应用程序,以验证我们支持您的应用程序所需的所有功能。