Kinesis Data Analytics for Java Applications:工作方式 - Amazon Kinesis Data Analytics
AWS 文档中描述的 AWS 服务或功能可能因区域而异。要查看适用于中国区域的差异,请参阅中国的 AWS 服务入门

Kinesis Data Analytics for Java Applications:工作方式

Kinesis Data Analytics 是一个完全托管的 AWS 服务,允许您使用 Apache Flink 应用程序处理流数据并生成输出。然后,应用程序将输出写入到配置的目标。

您可以在本地构建 Apache Flink 应用程序,然后将应用程序代码上传到 Amazon S3 存储桶以使 Kinesis Data Analytics 服务能够使用该代码。应用程序是使用 Flink 编程模型构建的。大多数适用于 Java 的 Kinesis Data Analytics 应用程序主要使用 DataStream API。您也可以使用其他 Flink API,但在构建流应用程序时很少使用这些 API。

Apache Flink 编程模型基于两个构建块:

  • 数据流:连续数据记录流的结构化表示形式。

  • 转换操作符:将一个或多个数据流作为输入,并生成一个或多个数据流以作为输出。

您可以添加称为连接器 的源或接收器,以将数据流连接到外部数据。典型的应用程序包含至少一个具有源的数据流、一个具有一个或多个操作符的数据流以及至少一个数据接收器。