本文属于机器翻译版本。若本译文内容与英语原文存在差异,则一律以英文原文为准。
AAmazon Kinesis Data Analytics Flink
借助适用于 Apache Flink 的 Amazon Kinesis 数据分析,你可以使用 Java、Scala 或 SQL 来处理和分析流数据。该服务使您能够针对流媒体源编写和运行代码,以执行时间序列分析、提供实时仪表板和创建实时指标。
你可以使用基于 A pache Fl
注意
尽管 Kinesis Data Analytics 支持用 Scala 版本 2.12 编写的 Apache Flink 应用程序,但本指南仅包含用 Java 编写的代码示例。
Kinesis Data Analytics 为您的 Apache Flink 应用程序提供底层基础架构。它实施一些核心功能,例如,预置计算资源、并行计算、自动扩展和应用程序备份(实施为检查点和快照)。你可以使用高级的 Flink 编程功能(例如运算符、函数、源代码和接收器),就像你自己托管 Flink 基础架构时使用它们一样。
入门
您可以先创建一个持续读取和处理流数据的 Kinesis Data Analytics 应用程序。然后,使用您选择的 IDE 编写代码,并使用实时流数据对其进行测试。您还可以配置希望 Kinesis Data Analytics 将结果发送到的目的地。
首先,我们建议您阅读以下章节: