入门:Flink 1.6.2 - Amazon Kinesis Data Analytics
Amazon Web Services 文档中描述的 Amazon Web Services 服务或功能可能因区域而异。要查看适用于中国区域的差异,请参阅 中国的 Amazon Web Services 服务入门 (PDF)

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

入门:Flink 1.6.2

本主题包含使用 Apache Flink 1.6.2 的入门指南 (DataStream API)教程版本。

Amazon Kinesis Data Analyts

为了处理数据,您的 Kinesis Data Analytics 应用程序使用 Java/Apache Maven 或 Scala 应用程序,该应用程序使用 Apache Flink 运行时处理输入并生成输出。

Amazon Kinesis Data Analytics

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

  • 源:应用程序通过 使用数据。源连接器从 Kinesis 数据流、Amazon S3 存储桶等读取数据。有关更多信息,请参阅

  • 操作符:应用程序使用一个或多个操作符 以处理数据。操作符可以转换、丰富或聚合数据。有关更多信息,请参阅DataStream API 操作员

  • 接收器:应用程序使用接收器 将生成的数据发送到外部源。Kinesis k 连接器将Data a a a a a a a FirehKinesis Data Firehose、有关更多信息,请参阅接收器

在创建、编和打应用程序后,将代码包上传到 Amazon Smple Storage Service (Amazon S3) 存储桶。然后 Kinesis Data Analytics 建 您传入代码包位置、作为流数据源的 Kinesis 数据流,通常传入接收应用程序处理过的数据流或文件位置。

完成练习的先决条件

要完成本指南中的步骤,您必须满足以下条件:

要开始,请转到步骤 1:设置 Amazon 账户并创建管理员用户