适用于 Apache Flink 的托管服务的 Java 示例 - Managed Service for Apache Flink

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

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

适用于 Apache Flink 的托管服务的 Java 示例

以下示例演示如何创建用 Java 编写的应用程序。

注意

大多数示例都设计为既可以在本地运行，也可以在您选择的开发计算机上运行，也可以在适用于 Apache Flink 的亚马逊托管服务上运行。IDE它们演示了可用于传递应用程序参数的机制，以及如何正确设置依赖关系，以便在不做任何更改的情况下在两个环境中运行应用程序。

此示例显示了一个简单的应用程序，该应用程序使用从 Kinesis 数据流中读取数据并写入另一个 Kinesis 数据流。DataStream API该示例演示了如何使用正确的依赖项设置文件，构建 uber-，然后解析配置参数JAR，这样您就可以在本地、在自己的IDE和 Apache Flink 的 Amazon 托管服务上运行应用程序。

代码示例：GettingStarted

此示例显示了一个使用TableAPI和的简单应用程序SQL。它演示了如何将DataStreamAPI与TableAPI或集成到同一 Java 应用程序SQL中。它还演示了如何使用DataGen连接器在 Flink 应用程序本身内部生成随机测试数据，无需外部数据生成器。

完整示例：GettingStartedTable

此示例演示如何使用将DataStreamAPIJSON文件写入 S3 存储桶。FileSink

代码示例：S3Sink

此示例演示如何使用标准使用器或 Kinesis 数据流配置消耗源EFO，以及如何为 Kinesis 数据流设置接收器。

代码示例：KinesisConnectors

此示例说明如何将数据发送到亚马逊 Data Firehose（以前称为 Kinesis Data Firehose）。

代码示例：KinesisFirehoseSink

此示例演示了中四种类型的窗口聚合。DataStream API

  1. 基于处理时间的滑动窗口

  2. 基于事件时间的滑动窗口

  3. 基于处理时间的翻滚窗口

  4. 基于事件时间的翻滚窗口

代码示例：开窗

此示例说明如何将自定义指标添加到您的 Flink 应用程序并将其发送到 CloudWatch 指标。

代码示例：CustomMetrics