什么是 Amazon Kinesis Data Analytics for Apache Flink? - Amazon Kinesis Data Analytics
Amazon Web Services 文档中描述的 Amazon Web Services 服务或功能可能因区域而异。要查看适用于中国区域的差异,请参阅中国的 Amazon Web Services 服务入门

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

什么是 Amazon Kinesis Data Analytics for Apache Flink?

借助适用于 Apache Flink 的 Amazon Kinesis Data Analytics,您可以使用 Java、Scala 或 SQL 处理和分析流数据。该服务用于根据流式源创建和运行代码,以便执行时间序列分析,为实时控制面板提供信息以及创建实时指标。

您可以使用基于以下基于的开源库在 Kinesis Data Analytics 中构建 Java 和 Scala 应用程序。Apache Flink. Apache Flink 是处理数据流的常用框架和引擎。

注意

尽管 Kinesis Data Analytics 支持使用 Scala 版本 2.12 编写的 Apache Flink 应用程序,但本指南只包含用 Java 编写的代码示例。

Kinesis Data Analytics 为 Apache Flink 应用程序提供基础设施。它实施一些核心功能,例如,预置计算资源、并行计算、自动扩展和应用程序备份(实施为检查点和快照)。您可以使用高级 Flink 编程功能(如操作符、函数、源和接收器),使用的方式与自行托管 Flink 基础设施时一样。

入门

您可以从创建持续读取和处理流数据的 Kinesis Data Analytics 应用程序开始。然后,使用所选的 IDE 编写代码,并使用实时流数据对其进行测试。您还可以配置 Kinesis Data Analytics 要将结果发送到的目标。

首先,我们建议您阅读以下章节: