建立使用 Apache Beam 的 Managed Service in Apache Flink 應用程式 - Managed Service for Apache Flink
將 Apache Beam 與 Managed Service for Apache Flink 搭配使用Beam 功能

Amazon Managed Service for Apache Flink 之前被稱為 Amazon Kinesis Data Analytics for Apache Flink。

本文為英文版的機器翻譯版本，如內容有任何歧義或不一致之處，概以英文版為準。

建立使用 Apache Beam 的 Managed Service in Apache Flink 應用程式

您可以將 Apache Beam 架構與 Managed Service for Apache Flink 搭配使用來處理串流資料。使用 Apache Beam 的 Managed Service for Apache Flink 應用程式使用 Apache Flink 執行器來執行 Beam 管道。

如需關於如何在 Managed Service for Apache Flink 中使用 Apache Beam 的教學課程，請參閱搭配使用 CloudFormation 與 Managed Service for Apache Flink。

本主題包含下列章節：

將 Apache Beam 與 Managed Service for Apache Flink 搭配使用

請注意下列有關將 Apache Flink 執行器與 Managed Service for Apache Flink 搭配使用的相關資訊：

  • 在 Managed Service in Apache Flink 主控台中無法檢視 Apache Beam 指標。

  • 只有使用 Apache Flink 1.8 及以上版本的 Managed Service for Apache Flink 應用程式才支援 Apache Beam。使用 Apache Flink 1.6 版的 Managed Service for Apache Flink 應用程式不支援 Apache Beam。

Beam 功能

Managed Service for Apache Flink 與 Apache Flink 執行器支援相同的 Apache Beam 功能。如需 Apache Flink 執行器所支援功能的相關資訊，請參閱 Beam 相容性矩陣。

建議您在 Managed Service for Apache Flink 服務中測試 Apache Flink 應用程式，以確認我們是否支援您的應用程式所需的全部功能。