Amazon Managed Service for Apache Flink 入门(表 API) - Managed Service for Apache Flink
Amazon Web Services 文档中描述的 Amazon Web Services 服务或功能可能因区域而异。要查看适用于中国区域的差异,请参阅 中国的 Amazon Web Services 服务入门 (PDF)

Amazon Managed Service for Apache Flink 之前称为 Amazon Kinesis Data Analytics for Apache Flink。

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

Amazon Managed Service for Apache Flink 入门(表 API)

本节向您介绍Managed Service for Apache Flink和 表 API 的基本概念。它介绍了可用于创建和测试应用程序的选项。它还提供了相应的说明以安装所需的工具,以完成本指南中的教程和创建第一个应用程序。

Managed Service for Apache Flink 应用程序组件

为了处理数据,您的Managed Service for Apache Flink 应用程序使用 Java/Apache Maven 或 Scala 应用程序,该应用程序使用 Apache Flink 运行时处理输入和生成输出。

Managed Service for Apache Flink 应用程序包含以下组件:

  • 运行时属性:您可以使用运行时属性 配置应用程序,而无需重新编译应用程序代码。

  • 表源:应用程序通过源来使用数据。连接器从 Kinesis 数据流、Amazon MSK 主题或类似主题中读取数据。有关更多信息,请参阅 表 API 来源

  • 函数:应用程序使用一个或多个函数处理数据。函数可以转换、丰富或聚合数据。

  • 接收器:应用程序使用接收器 将生成的数据发送到外部源。接收器连接器将数据写入 Kinesis 数据流、Kinesis Data Firehose 流、Amazon MSK 主题、Amazon S3 存储桶等。有关更多信息,请参阅 表 API 接收器

在创建、编译和打包应用程序后,您可以将代码包上传到 Amazon S3 存储桶中。然后,您创建一个 Managed Service for Apache Flink 应用程序。您在代码包位置中传入一个 Amazon MSK 主题以作为流数据源,它通常是接收应用程序处理的数据的流或文件位置。

先决条件

在开始本教程之前,请先完成 适用于 Apache Flink 的亚马逊托管服务 (DataStream API) 入门中的前两个步骤:

要开始使用,请参阅 创建应用程序